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

README.md

sarama

Go Reference OpenSSF Scorecard OpenSSF Best Practices

Sarama is an MIT-licensed Go client library for Apache Kafka.

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. However, older releases of Kafka are still likely to work.

Sarama follows semantic versioning and provides API stability via the standard Go module version numbering scheme.

A changelog is available here.

Contributing