tangs b030ce89ca openbilibili 6 gadi atpakaļ
..
BUILD b030ce89ca openbilibili 6 gadi atpakaļ
CHANGELOG.md b030ce89ca openbilibili 6 gadi atpakaļ
LICENSE b030ce89ca openbilibili 6 gadi atpakaļ
Makefile b030ce89ca openbilibili 6 gadi atpakaļ
README.md b030ce89ca openbilibili 6 gadi atpakaļ
Vagrantfile b030ce89ca openbilibili 6 gadi atpakaļ
acl_bindings.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_create_request.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_create_response.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_delete_request.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_delete_response.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_describe_request.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_describe_response.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_filter.go b030ce89ca openbilibili 6 gadi atpakaļ
acl_types.go b030ce89ca openbilibili 6 gadi atpakaļ
add_offsets_to_txn_request.go b030ce89ca openbilibili 6 gadi atpakaļ
add_offsets_to_txn_response.go b030ce89ca openbilibili 6 gadi atpakaļ
add_partitions_to_txn_request.go b030ce89ca openbilibili 6 gadi atpakaļ
add_partitions_to_txn_response.go b030ce89ca openbilibili 6 gadi atpakaļ
admin.go b030ce89ca openbilibili 6 gadi atpakaļ
alter_configs_request.go b030ce89ca openbilibili 6 gadi atpakaļ
alter_configs_response.go b030ce89ca openbilibili 6 gadi atpakaļ
api_versions_request.go b030ce89ca openbilibili 6 gadi atpakaļ
api_versions_response.go b030ce89ca openbilibili 6 gadi atpakaļ
async_producer.go b030ce89ca openbilibili 6 gadi atpakaļ
broker.go b030ce89ca openbilibili 6 gadi atpakaļ
client.go b030ce89ca openbilibili 6 gadi atpakaļ
config.go b030ce89ca openbilibili 6 gadi atpakaļ
config_resource_type.go b030ce89ca openbilibili 6 gadi atpakaļ
consumer.go b030ce89ca openbilibili 6 gadi atpakaļ
consumer_group_members.go b030ce89ca openbilibili 6 gadi atpakaļ
consumer_metadata_request.go b030ce89ca openbilibili 6 gadi atpakaļ
consumer_metadata_response.go b030ce89ca openbilibili 6 gadi atpakaļ
crc32_field.go b030ce89ca openbilibili 6 gadi atpakaļ
create_partitions_request.go b030ce89ca openbilibili 6 gadi atpakaļ
create_partitions_response.go b030ce89ca openbilibili 6 gadi atpakaļ
create_topics_request.go b030ce89ca openbilibili 6 gadi atpakaļ
create_topics_response.go b030ce89ca openbilibili 6 gadi atpakaļ
delete_groups_request.go b030ce89ca openbilibili 6 gadi atpakaļ
delete_groups_response.go b030ce89ca openbilibili 6 gadi atpakaļ
delete_records_request.go b030ce89ca openbilibili 6 gadi atpakaļ
delete_records_response.go b030ce89ca openbilibili 6 gadi atpakaļ
delete_topics_request.go b030ce89ca openbilibili 6 gadi atpakaļ
delete_topics_response.go b030ce89ca openbilibili 6 gadi atpakaļ
describe_configs_request.go b030ce89ca openbilibili 6 gadi atpakaļ
describe_configs_response.go b030ce89ca openbilibili 6 gadi atpakaļ
describe_groups_request.go b030ce89ca openbilibili 6 gadi atpakaļ
describe_groups_response.go b030ce89ca openbilibili 6 gadi atpakaļ
dev.yml b030ce89ca openbilibili 6 gadi atpakaļ
encoder_decoder.go b030ce89ca openbilibili 6 gadi atpakaļ
end_txn_request.go b030ce89ca openbilibili 6 gadi atpakaļ
end_txn_response.go b030ce89ca openbilibili 6 gadi atpakaļ
errors.go b030ce89ca openbilibili 6 gadi atpakaļ
fetch_request.go b030ce89ca openbilibili 6 gadi atpakaļ
fetch_response.go b030ce89ca openbilibili 6 gadi atpakaļ
find_coordinator_request.go b030ce89ca openbilibili 6 gadi atpakaļ
find_coordinator_response.go b030ce89ca openbilibili 6 gadi atpakaļ
heartbeat_request.go b030ce89ca openbilibili 6 gadi atpakaļ
heartbeat_response.go b030ce89ca openbilibili 6 gadi atpakaļ
init_producer_id_request.go b030ce89ca openbilibili 6 gadi atpakaļ
init_producer_id_response.go b030ce89ca openbilibili 6 gadi atpakaļ
join_group_request.go b030ce89ca openbilibili 6 gadi atpakaļ
join_group_response.go b030ce89ca openbilibili 6 gadi atpakaļ
leave_group_request.go b030ce89ca openbilibili 6 gadi atpakaļ
leave_group_response.go b030ce89ca openbilibili 6 gadi atpakaļ
length_field.go b030ce89ca openbilibili 6 gadi atpakaļ
list_groups_request.go b030ce89ca openbilibili 6 gadi atpakaļ
list_groups_response.go b030ce89ca openbilibili 6 gadi atpakaļ
message.go b030ce89ca openbilibili 6 gadi atpakaļ
message_set.go b030ce89ca openbilibili 6 gadi atpakaļ
metadata_request.go b030ce89ca openbilibili 6 gadi atpakaļ
metadata_response.go b030ce89ca openbilibili 6 gadi atpakaļ
metrics.go b030ce89ca openbilibili 6 gadi atpakaļ
mockbroker.go b030ce89ca openbilibili 6 gadi atpakaļ
mockresponses.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_commit_request.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_commit_response.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_fetch_request.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_fetch_response.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_manager.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_request.go b030ce89ca openbilibili 6 gadi atpakaļ
offset_response.go b030ce89ca openbilibili 6 gadi atpakaļ
packet_decoder.go b030ce89ca openbilibili 6 gadi atpakaļ
packet_encoder.go b030ce89ca openbilibili 6 gadi atpakaļ
partitioner.go b030ce89ca openbilibili 6 gadi atpakaļ
prep_encoder.go b030ce89ca openbilibili 6 gadi atpakaļ
produce_request.go b030ce89ca openbilibili 6 gadi atpakaļ
produce_response.go b030ce89ca openbilibili 6 gadi atpakaļ
produce_set.go b030ce89ca openbilibili 6 gadi atpakaļ
real_decoder.go b030ce89ca openbilibili 6 gadi atpakaļ
real_encoder.go b030ce89ca openbilibili 6 gadi atpakaļ
record.go b030ce89ca openbilibili 6 gadi atpakaļ
record_batch.go b030ce89ca openbilibili 6 gadi atpakaļ
records.go b030ce89ca openbilibili 6 gadi atpakaļ
request.go b030ce89ca openbilibili 6 gadi atpakaļ
response_header.go b030ce89ca openbilibili 6 gadi atpakaļ
sarama.go b030ce89ca openbilibili 6 gadi atpakaļ
sasl_handshake_request.go b030ce89ca openbilibili 6 gadi atpakaļ
sasl_handshake_response.go b030ce89ca openbilibili 6 gadi atpakaļ
sync_group_request.go b030ce89ca openbilibili 6 gadi atpakaļ
sync_group_response.go b030ce89ca openbilibili 6 gadi atpakaļ
sync_producer.go b030ce89ca openbilibili 6 gadi atpakaļ
timestamp.go b030ce89ca openbilibili 6 gadi atpakaļ
txn_offset_commit_request.go b030ce89ca openbilibili 6 gadi atpakaļ
txn_offset_commit_response.go b030ce89ca openbilibili 6 gadi atpakaļ
utils.go b030ce89ca openbilibili 6 gadi atpakaļ

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