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

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