baishaojie dcf2cbd820 first commit hai 1 ano
..
.gitignore dcf2cbd820 first commit hai 1 ano
.golangci.yml dcf2cbd820 first commit hai 1 ano
CHANGELOG.md dcf2cbd820 first commit hai 1 ano
LICENSE dcf2cbd820 first commit hai 1 ano
Makefile dcf2cbd820 first commit hai 1 ano
README.md dcf2cbd820 first commit hai 1 ano
Vagrantfile dcf2cbd820 first commit hai 1 ano
acl_bindings.go dcf2cbd820 first commit hai 1 ano
acl_create_request.go dcf2cbd820 first commit hai 1 ano
acl_create_response.go dcf2cbd820 first commit hai 1 ano
acl_delete_request.go dcf2cbd820 first commit hai 1 ano
acl_delete_response.go dcf2cbd820 first commit hai 1 ano
acl_describe_request.go dcf2cbd820 first commit hai 1 ano
acl_describe_response.go dcf2cbd820 first commit hai 1 ano
acl_filter.go dcf2cbd820 first commit hai 1 ano
acl_types.go dcf2cbd820 first commit hai 1 ano
add_offsets_to_txn_request.go dcf2cbd820 first commit hai 1 ano
add_offsets_to_txn_response.go dcf2cbd820 first commit hai 1 ano
add_partitions_to_txn_request.go dcf2cbd820 first commit hai 1 ano
add_partitions_to_txn_response.go dcf2cbd820 first commit hai 1 ano
admin.go dcf2cbd820 first commit hai 1 ano
alter_client_quotas_request.go dcf2cbd820 first commit hai 1 ano
alter_client_quotas_response.go dcf2cbd820 first commit hai 1 ano
alter_configs_request.go dcf2cbd820 first commit hai 1 ano
alter_configs_response.go dcf2cbd820 first commit hai 1 ano
alter_partition_reassignments_request.go dcf2cbd820 first commit hai 1 ano
alter_partition_reassignments_response.go dcf2cbd820 first commit hai 1 ano
alter_user_scram_credentials_request.go dcf2cbd820 first commit hai 1 ano
alter_user_scram_credentials_response.go dcf2cbd820 first commit hai 1 ano
api_versions_request.go dcf2cbd820 first commit hai 1 ano
api_versions_response.go dcf2cbd820 first commit hai 1 ano
async_producer.go dcf2cbd820 first commit hai 1 ano
balance_strategy.go dcf2cbd820 first commit hai 1 ano
broker.go dcf2cbd820 first commit hai 1 ano
client.go dcf2cbd820 first commit hai 1 ano
compress.go dcf2cbd820 first commit hai 1 ano
config.go dcf2cbd820 first commit hai 1 ano
config_resource_type.go dcf2cbd820 first commit hai 1 ano
consumer.go dcf2cbd820 first commit hai 1 ano
consumer_group.go dcf2cbd820 first commit hai 1 ano
consumer_group_members.go dcf2cbd820 first commit hai 1 ano
consumer_metadata_request.go dcf2cbd820 first commit hai 1 ano
consumer_metadata_response.go dcf2cbd820 first commit hai 1 ano
control_record.go dcf2cbd820 first commit hai 1 ano
crc32_field.go dcf2cbd820 first commit hai 1 ano
create_partitions_request.go dcf2cbd820 first commit hai 1 ano
create_partitions_response.go dcf2cbd820 first commit hai 1 ano
create_topics_request.go dcf2cbd820 first commit hai 1 ano
create_topics_response.go dcf2cbd820 first commit hai 1 ano
decompress.go dcf2cbd820 first commit hai 1 ano
delete_groups_request.go dcf2cbd820 first commit hai 1 ano
delete_groups_response.go dcf2cbd820 first commit hai 1 ano
delete_offsets_request.go dcf2cbd820 first commit hai 1 ano
delete_offsets_response.go dcf2cbd820 first commit hai 1 ano
delete_records_request.go dcf2cbd820 first commit hai 1 ano
delete_records_response.go dcf2cbd820 first commit hai 1 ano
delete_topics_request.go dcf2cbd820 first commit hai 1 ano
delete_topics_response.go dcf2cbd820 first commit hai 1 ano
describe_client_quotas_request.go dcf2cbd820 first commit hai 1 ano
describe_client_quotas_response.go dcf2cbd820 first commit hai 1 ano
describe_configs_request.go dcf2cbd820 first commit hai 1 ano
describe_configs_response.go dcf2cbd820 first commit hai 1 ano
describe_groups_request.go dcf2cbd820 first commit hai 1 ano
describe_groups_response.go dcf2cbd820 first commit hai 1 ano
describe_log_dirs_request.go dcf2cbd820 first commit hai 1 ano
describe_log_dirs_response.go dcf2cbd820 first commit hai 1 ano
describe_user_scram_credentials_request.go dcf2cbd820 first commit hai 1 ano
describe_user_scram_credentials_response.go dcf2cbd820 first commit hai 1 ano
dev.yml dcf2cbd820 first commit hai 1 ano
docker-compose.yml dcf2cbd820 first commit hai 1 ano
encoder_decoder.go dcf2cbd820 first commit hai 1 ano
end_txn_request.go dcf2cbd820 first commit hai 1 ano
end_txn_response.go dcf2cbd820 first commit hai 1 ano
errors.go dcf2cbd820 first commit hai 1 ano
fetch_request.go dcf2cbd820 first commit hai 1 ano
fetch_response.go dcf2cbd820 first commit hai 1 ano
find_coordinator_request.go dcf2cbd820 first commit hai 1 ano
find_coordinator_response.go dcf2cbd820 first commit hai 1 ano
go.mod dcf2cbd820 first commit hai 1 ano
go.sum dcf2cbd820 first commit hai 1 ano
gssapi_kerberos.go dcf2cbd820 first commit hai 1 ano
heartbeat_request.go dcf2cbd820 first commit hai 1 ano
heartbeat_response.go dcf2cbd820 first commit hai 1 ano
incremental_alter_configs_request.go dcf2cbd820 first commit hai 1 ano
incremental_alter_configs_response.go dcf2cbd820 first commit hai 1 ano
init_producer_id_request.go dcf2cbd820 first commit hai 1 ano
init_producer_id_response.go dcf2cbd820 first commit hai 1 ano
interceptors.go dcf2cbd820 first commit hai 1 ano
join_group_request.go dcf2cbd820 first commit hai 1 ano
join_group_response.go dcf2cbd820 first commit hai 1 ano
kerberos_client.go dcf2cbd820 first commit hai 1 ano
leave_group_request.go dcf2cbd820 first commit hai 1 ano
leave_group_response.go dcf2cbd820 first commit hai 1 ano
length_field.go dcf2cbd820 first commit hai 1 ano
list_groups_request.go dcf2cbd820 first commit hai 1 ano
list_groups_response.go dcf2cbd820 first commit hai 1 ano
list_partition_reassignments_request.go dcf2cbd820 first commit hai 1 ano
list_partition_reassignments_response.go dcf2cbd820 first commit hai 1 ano
message.go dcf2cbd820 first commit hai 1 ano
message_set.go dcf2cbd820 first commit hai 1 ano
metadata_request.go dcf2cbd820 first commit hai 1 ano
metadata_response.go dcf2cbd820 first commit hai 1 ano
metrics.go dcf2cbd820 first commit hai 1 ano
mockbroker.go dcf2cbd820 first commit hai 1 ano
mockkerberos.go dcf2cbd820 first commit hai 1 ano
mockresponses.go dcf2cbd820 first commit hai 1 ano
offset_commit_request.go dcf2cbd820 first commit hai 1 ano
offset_commit_response.go dcf2cbd820 first commit hai 1 ano
offset_fetch_request.go dcf2cbd820 first commit hai 1 ano
offset_fetch_response.go dcf2cbd820 first commit hai 1 ano
offset_manager.go dcf2cbd820 first commit hai 1 ano
offset_request.go dcf2cbd820 first commit hai 1 ano
offset_response.go dcf2cbd820 first commit hai 1 ano
packet_decoder.go dcf2cbd820 first commit hai 1 ano
packet_encoder.go dcf2cbd820 first commit hai 1 ano
partitioner.go dcf2cbd820 first commit hai 1 ano
prep_encoder.go dcf2cbd820 first commit hai 1 ano
produce_request.go dcf2cbd820 first commit hai 1 ano
produce_response.go dcf2cbd820 first commit hai 1 ano
produce_set.go dcf2cbd820 first commit hai 1 ano
quota_types.go dcf2cbd820 first commit hai 1 ano
real_decoder.go dcf2cbd820 first commit hai 1 ano
real_encoder.go dcf2cbd820 first commit hai 1 ano
record.go dcf2cbd820 first commit hai 1 ano
record_batch.go dcf2cbd820 first commit hai 1 ano
records.go dcf2cbd820 first commit hai 1 ano
request.go dcf2cbd820 first commit hai 1 ano
response_header.go dcf2cbd820 first commit hai 1 ano
sarama.go dcf2cbd820 first commit hai 1 ano
sasl_authenticate_request.go dcf2cbd820 first commit hai 1 ano
sasl_authenticate_response.go dcf2cbd820 first commit hai 1 ano
sasl_handshake_request.go dcf2cbd820 first commit hai 1 ano
sasl_handshake_response.go dcf2cbd820 first commit hai 1 ano
scram_formatter.go dcf2cbd820 first commit hai 1 ano
sticky_assignor_user_data.go dcf2cbd820 first commit hai 1 ano
sync_group_request.go dcf2cbd820 first commit hai 1 ano
sync_group_response.go dcf2cbd820 first commit hai 1 ano
sync_producer.go dcf2cbd820 first commit hai 1 ano
timestamp.go dcf2cbd820 first commit hai 1 ano
txn_offset_commit_request.go dcf2cbd820 first commit hai 1 ano
txn_offset_commit_response.go dcf2cbd820 first commit hai 1 ano
utils.go dcf2cbd820 first commit hai 1 ano
version.go dcf2cbd820 first commit hai 1 ano
zstd.go dcf2cbd820 first commit hai 1 ano

README.md

sarama

Go Reference 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 pkg.go.dev.
  • 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.16, and Kafka 2.7 through 2.8, 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