Lourens Naudé
ab2cd98eff
Initial pass at a basic SerDe implementation
|
%!s(int64=4) %!d(string=hai) anos | |
|---|---|---|
| .github | %!s(int64=4) %!d(string=hai) anos | |
| examples | %!s(int64=4) %!d(string=hai) anos | |
| mocks | %!s(int64=4) %!d(string=hai) anos | |
| tools | %!s(int64=4) %!d(string=hai) anos | |
| vagrant | %!s(int64=4) %!d(string=hai) anos | |
| .gitignore | %!s(int64=4) %!d(string=hai) anos | |
| .golangci.yml | %!s(int64=4) %!d(string=hai) anos | |
| CHANGELOG.md | %!s(int64=4) %!d(string=hai) anos | |
| LICENSE | %!s(int64=6) %!d(string=hai) anos | |
| Makefile | %!s(int64=4) %!d(string=hai) anos | |
| README.md | %!s(int64=4) %!d(string=hai) anos | |
| Vagrantfile | %!s(int64=4) %!d(string=hai) anos | |
| acl_bindings.go | %!s(int64=5) %!d(string=hai) anos | |
| acl_create_request.go | %!s(int64=4) %!d(string=hai) anos | |
| acl_create_request_test.go | %!s(int64=5) %!d(string=hai) anos | |
| acl_create_response.go | %!s(int64=4) %!d(string=hai) anos | |
| acl_create_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| acl_delete_request.go | %!s(int64=4) %!d(string=hai) anos | |
| acl_delete_request_test.go | %!s(int64=5) %!d(string=hai) anos | |
| acl_delete_response.go | %!s(int64=4) %!d(string=hai) anos | |
| acl_delete_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| acl_describe_request.go | %!s(int64=4) %!d(string=hai) anos | |
| acl_describe_request_test.go | %!s(int64=5) %!d(string=hai) anos | |
| acl_describe_response.go | %!s(int64=4) %!d(string=hai) anos | |
| acl_describe_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| acl_filter.go | %!s(int64=5) %!d(string=hai) anos | |
| acl_types.go | %!s(int64=5) %!d(string=hai) anos | |
| add_offsets_to_txn_request.go | %!s(int64=4) %!d(string=hai) anos | |
| add_offsets_to_txn_request_test.go | %!s(int64=7) %!d(string=hai) anos | |
| add_offsets_to_txn_response.go | %!s(int64=4) %!d(string=hai) anos | |
| add_offsets_to_txn_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| add_partitions_to_txn_request.go | %!s(int64=4) %!d(string=hai) anos | |
| add_partitions_to_txn_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| add_partitions_to_txn_response.go | %!s(int64=4) %!d(string=hai) anos | |
| add_partitions_to_txn_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| admin.go | %!s(int64=4) %!d(string=hai) anos | |
| admin_test.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_configs_request.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_configs_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_configs_response.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_configs_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_partition_reassignments_request.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_partition_reassignments_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_partition_reassignments_response.go | %!s(int64=4) %!d(string=hai) anos | |
| alter_partition_reassignments_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| api_versions_request.go | %!s(int64=4) %!d(string=hai) anos | |
| api_versions_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| api_versions_response.go | %!s(int64=4) %!d(string=hai) anos | |
| api_versions_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| async_producer.go | %!s(int64=4) %!d(string=hai) anos | |
| async_producer_test.go | %!s(int64=4) %!d(string=hai) anos | |
| balance_strategy.go | %!s(int64=4) %!d(string=hai) anos | |
| balance_strategy_test.go | %!s(int64=4) %!d(string=hai) anos | |
| broker.go | %!s(int64=4) %!d(string=hai) anos | |
| broker_test.go | %!s(int64=4) %!d(string=hai) anos | |
| client.go | %!s(int64=4) %!d(string=hai) anos | |
| client_test.go | %!s(int64=4) %!d(string=hai) anos | |
| client_tls_test.go | %!s(int64=4) %!d(string=hai) anos | |
| compress.go | %!s(int64=4) %!d(string=hai) anos | |
| config.go | %!s(int64=4) %!d(string=hai) anos | |
| config_resource_type.go | %!s(int64=5) %!d(string=hai) anos | |
| config_test.go | %!s(int64=4) %!d(string=hai) anos | |
| consumer.go | %!s(int64=4) %!d(string=hai) anos | |
| consumer_group.go | %!s(int64=4) %!d(string=hai) anos | |
| consumer_group_members.go | %!s(int64=6) %!d(string=hai) anos | |
| consumer_group_members_test.go | %!s(int64=7) %!d(string=hai) anos | |
| consumer_group_test.go | %!s(int64=4) %!d(string=hai) anos | |
| consumer_metadata_request.go | %!s(int64=4) %!d(string=hai) anos | |
| consumer_metadata_request_test.go | %!s(int64=7) %!d(string=hai) anos | |
| consumer_metadata_response.go | %!s(int64=4) %!d(string=hai) anos | |
| consumer_metadata_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| consumer_test.go | %!s(int64=4) %!d(string=hai) anos | |
| control_record.go | %!s(int64=5) %!d(string=hai) anos | |
| control_record_test.go | %!s(int64=5) %!d(string=hai) anos | |
| crc32_field.go | %!s(int64=5) %!d(string=hai) anos | |
| create_partitions_request.go | %!s(int64=4) %!d(string=hai) anos | |
| create_partitions_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| create_partitions_response.go | %!s(int64=4) %!d(string=hai) anos | |
| create_partitions_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| create_topics_request.go | %!s(int64=4) %!d(string=hai) anos | |
| create_topics_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| create_topics_response.go | %!s(int64=4) %!d(string=hai) anos | |
| create_topics_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| decompress.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_groups_request.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_groups_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| delete_groups_response.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_groups_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| delete_records_request.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_records_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| delete_records_response.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_records_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| delete_topics_request.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_topics_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| delete_topics_response.go | %!s(int64=4) %!d(string=hai) anos | |
| delete_topics_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| describe_configs_request.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_configs_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_configs_response.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_configs_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_groups_request.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_groups_request_test.go | %!s(int64=9) %!d(string=hai) anos | |
| describe_groups_response.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_groups_response_test.go | %!s(int64=8) %!d(string=hai) anos | |
| describe_log_dirs_request.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_log_dirs_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_log_dirs_response.go | %!s(int64=4) %!d(string=hai) anos | |
| describe_log_dirs_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| deserializer.go | %!s(int64=4) %!d(string=hai) anos | |
| dev.yml | %!s(int64=4) %!d(string=hai) anos | |
| docker-compose.yml | %!s(int64=4) %!d(string=hai) anos | |
| encoder_decoder.go | %!s(int64=4) %!d(string=hai) anos | |
| end_txn_request.go | %!s(int64=4) %!d(string=hai) anos | |
| end_txn_request_test.go | %!s(int64=7) %!d(string=hai) anos | |
| end_txn_response.go | %!s(int64=4) %!d(string=hai) anos | |
| end_txn_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| errors.go | %!s(int64=4) %!d(string=hai) anos | |
| fetch_request.go | %!s(int64=4) %!d(string=hai) anos | |
| fetch_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| fetch_response.go | %!s(int64=4) %!d(string=hai) anos | |
| fetch_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| find_coordinator_request.go | %!s(int64=4) %!d(string=hai) anos | |
| find_coordinator_request_test.go | %!s(int64=7) %!d(string=hai) anos | |
| find_coordinator_response.go | %!s(int64=4) %!d(string=hai) anos | |
| find_coordinator_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| functional_client_test.go | %!s(int64=4) %!d(string=hai) anos | |
| functional_consumer_group_test.go | %!s(int64=4) %!d(string=hai) anos | |
| functional_consumer_test.go | %!s(int64=4) %!d(string=hai) anos | |
| functional_offset_manager_test.go | %!s(int64=4) %!d(string=hai) anos | |
| functional_producer_test.go | %!s(int64=4) %!d(string=hai) anos | |
| functional_test.go | %!s(int64=4) %!d(string=hai) anos | |
| go.mod | %!s(int64=4) %!d(string=hai) anos | |
| go.sum | %!s(int64=4) %!d(string=hai) anos | |
| gssapi_kerberos.go | %!s(int64=4) %!d(string=hai) anos | |
| heartbeat_request.go | %!s(int64=4) %!d(string=hai) anos | |
| heartbeat_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| heartbeat_response.go | %!s(int64=4) %!d(string=hai) anos | |
| heartbeat_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| init_producer_id_request.go | %!s(int64=4) %!d(string=hai) anos | |
| init_producer_id_request_test.go | %!s(int64=7) %!d(string=hai) anos | |
| init_producer_id_response.go | %!s(int64=4) %!d(string=hai) anos | |
| init_producer_id_response_test.go | %!s(int64=7) %!d(string=hai) anos | |
| join_group_request.go | %!s(int64=4) %!d(string=hai) anos | |
| join_group_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| join_group_response.go | %!s(int64=4) %!d(string=hai) anos | |
| join_group_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| kerberos_client.go | %!s(int64=4) %!d(string=hai) anos | |
| kerberos_client_test.go | %!s(int64=4) %!d(string=hai) anos | |
| leave_group_request.go | %!s(int64=4) %!d(string=hai) anos | |
| leave_group_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| leave_group_response.go | %!s(int64=4) %!d(string=hai) anos | |
| leave_group_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| length_field.go | %!s(int64=5) %!d(string=hai) anos | |
| list_groups_request.go | %!s(int64=4) %!d(string=hai) anos | |
| list_groups_request_test.go | %!s(int64=9) %!d(string=hai) anos | |
| list_groups_response.go | %!s(int64=4) %!d(string=hai) anos | |
| list_groups_response_test.go | %!s(int64=8) %!d(string=hai) anos | |
| list_partition_reassignments_request.go | %!s(int64=4) %!d(string=hai) anos | |
| list_partition_reassignments_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| list_partition_reassignments_response.go | %!s(int64=4) %!d(string=hai) anos | |
| list_partition_reassignments_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| message.go | %!s(int64=4) %!d(string=hai) anos | |
| message_set.go | %!s(int64=5) %!d(string=hai) anos | |
| message_test.go | %!s(int64=6) %!d(string=hai) anos | |
| metadata_request.go | %!s(int64=4) %!d(string=hai) anos | |
| metadata_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| metadata_response.go | %!s(int64=4) %!d(string=hai) anos | |
| metadata_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| metrics.go | %!s(int64=6) %!d(string=hai) anos | |
| metrics_test.go | %!s(int64=4) %!d(string=hai) anos | |
| mockbroker.go | %!s(int64=4) %!d(string=hai) anos | |
| mockkerberos.go | %!s(int64=4) %!d(string=hai) anos | |
| mockresponses.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_commit_request.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_commit_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| offset_commit_response.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_commit_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| offset_fetch_request.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_fetch_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| offset_fetch_response.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_fetch_response_test.go | %!s(int64=6) %!d(string=hai) anos | |
| offset_manager.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_manager_test.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_request.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| offset_response.go | %!s(int64=4) %!d(string=hai) anos | |
| offset_response_test.go | %!s(int64=8) %!d(string=hai) anos | |
| packet_decoder.go | %!s(int64=4) %!d(string=hai) anos | |
| packet_encoder.go | %!s(int64=4) %!d(string=hai) anos | |
| partitioner.go | %!s(int64=6) %!d(string=hai) anos | |
| partitioner_test.go | %!s(int64=6) %!d(string=hai) anos | |
| prep_encoder.go | %!s(int64=4) %!d(string=hai) anos | |
| produce_request.go | %!s(int64=4) %!d(string=hai) anos | |
| produce_request_test.go | %!s(int64=6) %!d(string=hai) anos | |
| produce_response.go | %!s(int64=4) %!d(string=hai) anos | |
| produce_response_test.go | %!s(int64=5) %!d(string=hai) anos | |
| produce_set.go | %!s(int64=4) %!d(string=hai) anos | |
| produce_set_test.go | %!s(int64=4) %!d(string=hai) anos | |
| real_decoder.go | %!s(int64=4) %!d(string=hai) anos | |
| real_encoder.go | %!s(int64=4) %!d(string=hai) anos | |
| record.go | %!s(int64=5) %!d(string=hai) anos | |
| record_batch.go | %!s(int64=5) %!d(string=hai) anos | |
| record_test.go | %!s(int64=4) %!d(string=hai) anos | |
| records.go | %!s(int64=4) %!d(string=hai) anos | |
| records_test.go | %!s(int64=5) %!d(string=hai) anos | |
| request.go | %!s(int64=4) %!d(string=hai) anos | |
| request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| response_header.go | %!s(int64=4) %!d(string=hai) anos | |
| response_header_test.go | %!s(int64=4) %!d(string=hai) anos | |
| sarama.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_authenticate_request.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_authenticate_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_authenticate_response.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_authenticate_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_handshake_request.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_handshake_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_handshake_response.go | %!s(int64=4) %!d(string=hai) anos | |
| sasl_handshake_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| serde.go | %!s(int64=4) %!d(string=hai) anos | |
| serializer.go | %!s(int64=4) %!d(string=hai) anos | |
| sticky_assignor_user_data.go | %!s(int64=5) %!d(string=hai) anos | |
| sticky_assignor_user_data_test.go | %!s(int64=5) %!d(string=hai) anos | |
| sync_group_request.go | %!s(int64=4) %!d(string=hai) anos | |
| sync_group_request_test.go | %!s(int64=9) %!d(string=hai) anos | |
| sync_group_response.go | %!s(int64=4) %!d(string=hai) anos | |
| sync_group_response_test.go | %!s(int64=8) %!d(string=hai) anos | |
| sync_producer.go | %!s(int64=6) %!d(string=hai) anos | |
| sync_producer_test.go | %!s(int64=5) %!d(string=hai) anos | |
| timestamp.go | %!s(int64=7) %!d(string=hai) anos | |
| txn_offset_commit_request.go | %!s(int64=4) %!d(string=hai) anos | |
| txn_offset_commit_request_test.go | %!s(int64=4) %!d(string=hai) anos | |
| txn_offset_commit_response.go | %!s(int64=4) %!d(string=hai) anos | |
| txn_offset_commit_response_test.go | %!s(int64=4) %!d(string=hai) anos | |
| utils.go | %!s(int64=4) %!d(string=hai) anos | |
| utils_test.go | %!s(int64=7) %!d(string=hai) anos | |
| zstd.go | %!s(int64=4) %!d(string=hai) anos |
README.md
sarama
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.12 through 1.14, and Kafka 2.3 through 2.5, 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
- Get started by checking our contribution guidelines.
- Read the Sarama wiki for more technical and design details.
- The Kafka Protocol Specification contains a wealth of useful information.
- For more general issues, there is a google group for Kafka client developers.
- If you have any questions, just ask!