Etusivu Tutki Apua
Rekisteröidy Kirjaudu sisään
xiongzhu
/
go-common
1
0
Fork 0
Tiedostot Ongelmat 0 Pull-pyynnöt 0 Wiki
Haara: master
Haarat Tagit
go-common
/
vendor
/
github.com
/
Shopify
/
sarama
x1ongzhu 4750177287 first commit 6 vuotta sitten
..
BUILD 4750177287 first commit 6 vuotta sitten
CHANGELOG.md 4750177287 first commit 6 vuotta sitten
LICENSE 4750177287 first commit 6 vuotta sitten
Makefile 4750177287 first commit 6 vuotta sitten
README.md 4750177287 first commit 6 vuotta sitten
Vagrantfile 4750177287 first commit 6 vuotta sitten
acl_bindings.go 4750177287 first commit 6 vuotta sitten
acl_create_request.go 4750177287 first commit 6 vuotta sitten
acl_create_response.go 4750177287 first commit 6 vuotta sitten
acl_delete_request.go 4750177287 first commit 6 vuotta sitten
acl_delete_response.go 4750177287 first commit 6 vuotta sitten
acl_describe_request.go 4750177287 first commit 6 vuotta sitten
acl_describe_response.go 4750177287 first commit 6 vuotta sitten
acl_filter.go 4750177287 first commit 6 vuotta sitten
acl_types.go 4750177287 first commit 6 vuotta sitten
add_offsets_to_txn_request.go 4750177287 first commit 6 vuotta sitten
add_offsets_to_txn_response.go 4750177287 first commit 6 vuotta sitten
add_partitions_to_txn_request.go 4750177287 first commit 6 vuotta sitten
add_partitions_to_txn_response.go 4750177287 first commit 6 vuotta sitten
admin.go 4750177287 first commit 6 vuotta sitten
alter_configs_request.go 4750177287 first commit 6 vuotta sitten
alter_configs_response.go 4750177287 first commit 6 vuotta sitten
api_versions_request.go 4750177287 first commit 6 vuotta sitten
api_versions_response.go 4750177287 first commit 6 vuotta sitten
async_producer.go 4750177287 first commit 6 vuotta sitten
broker.go 4750177287 first commit 6 vuotta sitten
client.go 4750177287 first commit 6 vuotta sitten
config.go 4750177287 first commit 6 vuotta sitten
config_resource_type.go 4750177287 first commit 6 vuotta sitten
consumer.go 4750177287 first commit 6 vuotta sitten
consumer_group_members.go 4750177287 first commit 6 vuotta sitten
consumer_metadata_request.go 4750177287 first commit 6 vuotta sitten
consumer_metadata_response.go 4750177287 first commit 6 vuotta sitten
crc32_field.go 4750177287 first commit 6 vuotta sitten
create_partitions_request.go 4750177287 first commit 6 vuotta sitten
create_partitions_response.go 4750177287 first commit 6 vuotta sitten
create_topics_request.go 4750177287 first commit 6 vuotta sitten
create_topics_response.go 4750177287 first commit 6 vuotta sitten
delete_groups_request.go 4750177287 first commit 6 vuotta sitten
delete_groups_response.go 4750177287 first commit 6 vuotta sitten
delete_records_request.go 4750177287 first commit 6 vuotta sitten
delete_records_response.go 4750177287 first commit 6 vuotta sitten
delete_topics_request.go 4750177287 first commit 6 vuotta sitten
delete_topics_response.go 4750177287 first commit 6 vuotta sitten
describe_configs_request.go 4750177287 first commit 6 vuotta sitten
describe_configs_response.go 4750177287 first commit 6 vuotta sitten
describe_groups_request.go 4750177287 first commit 6 vuotta sitten
describe_groups_response.go 4750177287 first commit 6 vuotta sitten
dev.yml 4750177287 first commit 6 vuotta sitten
encoder_decoder.go 4750177287 first commit 6 vuotta sitten
end_txn_request.go 4750177287 first commit 6 vuotta sitten
end_txn_response.go 4750177287 first commit 6 vuotta sitten
errors.go 4750177287 first commit 6 vuotta sitten
fetch_request.go 4750177287 first commit 6 vuotta sitten
fetch_response.go 4750177287 first commit 6 vuotta sitten
find_coordinator_request.go 4750177287 first commit 6 vuotta sitten
find_coordinator_response.go 4750177287 first commit 6 vuotta sitten
heartbeat_request.go 4750177287 first commit 6 vuotta sitten
heartbeat_response.go 4750177287 first commit 6 vuotta sitten
init_producer_id_request.go 4750177287 first commit 6 vuotta sitten
init_producer_id_response.go 4750177287 first commit 6 vuotta sitten
join_group_request.go 4750177287 first commit 6 vuotta sitten
join_group_response.go 4750177287 first commit 6 vuotta sitten
leave_group_request.go 4750177287 first commit 6 vuotta sitten
leave_group_response.go 4750177287 first commit 6 vuotta sitten
length_field.go 4750177287 first commit 6 vuotta sitten
list_groups_request.go 4750177287 first commit 6 vuotta sitten
list_groups_response.go 4750177287 first commit 6 vuotta sitten
message.go 4750177287 first commit 6 vuotta sitten
message_set.go 4750177287 first commit 6 vuotta sitten
metadata_request.go 4750177287 first commit 6 vuotta sitten
metadata_response.go 4750177287 first commit 6 vuotta sitten
metrics.go 4750177287 first commit 6 vuotta sitten
mockbroker.go 4750177287 first commit 6 vuotta sitten
mockresponses.go 4750177287 first commit 6 vuotta sitten
offset_commit_request.go 4750177287 first commit 6 vuotta sitten
offset_commit_response.go 4750177287 first commit 6 vuotta sitten
offset_fetch_request.go 4750177287 first commit 6 vuotta sitten
offset_fetch_response.go 4750177287 first commit 6 vuotta sitten
offset_manager.go 4750177287 first commit 6 vuotta sitten
offset_request.go 4750177287 first commit 6 vuotta sitten
offset_response.go 4750177287 first commit 6 vuotta sitten
packet_decoder.go 4750177287 first commit 6 vuotta sitten
packet_encoder.go 4750177287 first commit 6 vuotta sitten
partitioner.go 4750177287 first commit 6 vuotta sitten
prep_encoder.go 4750177287 first commit 6 vuotta sitten
produce_request.go 4750177287 first commit 6 vuotta sitten
produce_response.go 4750177287 first commit 6 vuotta sitten
produce_set.go 4750177287 first commit 6 vuotta sitten
real_decoder.go 4750177287 first commit 6 vuotta sitten
real_encoder.go 4750177287 first commit 6 vuotta sitten
record.go 4750177287 first commit 6 vuotta sitten
record_batch.go 4750177287 first commit 6 vuotta sitten
records.go 4750177287 first commit 6 vuotta sitten
request.go 4750177287 first commit 6 vuotta sitten
response_header.go 4750177287 first commit 6 vuotta sitten
sarama.go 4750177287 first commit 6 vuotta sitten
sasl_handshake_request.go 4750177287 first commit 6 vuotta sitten
sasl_handshake_response.go 4750177287 first commit 6 vuotta sitten
sync_group_request.go 4750177287 first commit 6 vuotta sitten
sync_group_response.go 4750177287 first commit 6 vuotta sitten
sync_producer.go 4750177287 first commit 6 vuotta sitten
timestamp.go 4750177287 first commit 6 vuotta sitten
txn_offset_commit_request.go 4750177287 first commit 6 vuotta sitten
txn_offset_commit_response.go 4750177287 first commit 6 vuotta sitten
utils.go 4750177287 first commit 6 vuotta sitten

README.md

sarama

GoDoc Build Status Coverage

Sarama is an MIT-licensed Go client library for Apache Kafka version 0.8 (and later).

Getting started

  • API documentation and examples are available via godoc.
  • Mocks for testing are available in the mocks subpackage.
  • The examples directory contains more elaborate example applications.
  • The tools directory contains command line tools that can be useful for testing, diagnostics, and instrumentation.

You might also want to look at the Frequently Asked Questions.

Compatibility and API stability

Sarama provides a "2 releases + 2 months" compatibility guarantee: we support the two latest stable releases of Kafka and Go, and we provide a two month grace period for older releases. This means we currently officially support Go 1.8 through 1.10, and Kafka 0.11 through 1.1, although older releases are still likely to work.

Sarama follows semantic versioning and provides API stability via the gopkg.in service. You can import a version with a guaranteed stable API via http://gopkg.in/Shopify/sarama.v1. A changelog is available here.

Contributing