p58036791
/
nightingale
forked from pneymrl2f/nightingale
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'e0584066a9'
${ noResults }
nightingale/vendor/github.com/Shopify/sarama
History
mt 163c116871
transfer support kafka (#227) 		5 years ago
..
.gitignore transfer support kafka (#227) 5 years ago
.golangci.yml transfer support kafka (#227) 5 years ago
CHANGELOG.md transfer support kafka (#227) 5 years ago
LICENSE transfer support kafka (#227) 5 years ago
Makefile transfer support kafka (#227) 5 years ago
README.md transfer support kafka (#227) 5 years ago
Vagrantfile transfer support kafka (#227) 5 years ago
acl_bindings.go transfer support kafka (#227) 5 years ago
acl_create_request.go transfer support kafka (#227) 5 years ago
acl_create_response.go transfer support kafka (#227) 5 years ago
acl_delete_request.go transfer support kafka (#227) 5 years ago
acl_delete_response.go transfer support kafka (#227) 5 years ago
acl_describe_request.go transfer support kafka (#227) 5 years ago
acl_describe_response.go transfer support kafka (#227) 5 years ago
acl_filter.go transfer support kafka (#227) 5 years ago
acl_types.go transfer support kafka (#227) 5 years ago
add_offsets_to_txn_request.go transfer support kafka (#227) 5 years ago
add_offsets_to_txn_response.go transfer support kafka (#227) 5 years ago
add_partitions_to_txn_request.go transfer support kafka (#227) 5 years ago
add_partitions_to_txn_response.go transfer support kafka (#227) 5 years ago
admin.go transfer support kafka (#227) 5 years ago
alter_configs_request.go transfer support kafka (#227) 5 years ago
alter_configs_response.go transfer support kafka (#227) 5 years ago
alter_partition_reassignments_request.go transfer support kafka (#227) 5 years ago
alter_partition_reassignments_response.go transfer support kafka (#227) 5 years ago
api_versions_request.go transfer support kafka (#227) 5 years ago
api_versions_response.go transfer support kafka (#227) 5 years ago
async_producer.go transfer support kafka (#227) 5 years ago
balance_strategy.go transfer support kafka (#227) 5 years ago
broker.go transfer support kafka (#227) 5 years ago
client.go transfer support kafka (#227) 5 years ago
compress.go transfer support kafka (#227) 5 years ago
config.go transfer support kafka (#227) 5 years ago
config_resource_type.go transfer support kafka (#227) 5 years ago
consumer.go transfer support kafka (#227) 5 years ago
consumer_group.go transfer support kafka (#227) 5 years ago
consumer_group_members.go transfer support kafka (#227) 5 years ago
consumer_metadata_request.go transfer support kafka (#227) 5 years ago
consumer_metadata_response.go transfer support kafka (#227) 5 years ago
control_record.go transfer support kafka (#227) 5 years ago
crc32_field.go transfer support kafka (#227) 5 years ago
create_partitions_request.go transfer support kafka (#227) 5 years ago
create_partitions_response.go transfer support kafka (#227) 5 years ago
create_topics_request.go transfer support kafka (#227) 5 years ago
create_topics_response.go transfer support kafka (#227) 5 years ago
decompress.go transfer support kafka (#227) 5 years ago
delete_groups_request.go transfer support kafka (#227) 5 years ago
delete_groups_response.go transfer support kafka (#227) 5 years ago
delete_records_request.go transfer support kafka (#227) 5 years ago
delete_records_response.go transfer support kafka (#227) 5 years ago
delete_topics_request.go transfer support kafka (#227) 5 years ago
delete_topics_response.go transfer support kafka (#227) 5 years ago
describe_configs_request.go transfer support kafka (#227) 5 years ago
describe_configs_response.go transfer support kafka (#227) 5 years ago
describe_groups_request.go transfer support kafka (#227) 5 years ago
describe_groups_response.go transfer support kafka (#227) 5 years ago
describe_log_dirs_request.go transfer support kafka (#227) 5 years ago
describe_log_dirs_response.go transfer support kafka (#227) 5 years ago
dev.yml transfer support kafka (#227) 5 years ago
encoder_decoder.go transfer support kafka (#227) 5 years ago
end_txn_request.go transfer support kafka (#227) 5 years ago
end_txn_response.go transfer support kafka (#227) 5 years ago
errors.go transfer support kafka (#227) 5 years ago
fetch_request.go transfer support kafka (#227) 5 years ago
fetch_response.go transfer support kafka (#227) 5 years ago
find_coordinator_request.go transfer support kafka (#227) 5 years ago
find_coordinator_response.go transfer support kafka (#227) 5 years ago
go.mod transfer support kafka (#227) 5 years ago
go.sum transfer support kafka (#227) 5 years ago
gssapi_kerberos.go transfer support kafka (#227) 5 years ago
heartbeat_request.go transfer support kafka (#227) 5 years ago
heartbeat_response.go transfer support kafka (#227) 5 years ago
init_producer_id_request.go transfer support kafka (#227) 5 years ago
init_producer_id_response.go transfer support kafka (#227) 5 years ago
join_group_request.go transfer support kafka (#227) 5 years ago
join_group_response.go transfer support kafka (#227) 5 years ago
kerberos_client.go transfer support kafka (#227) 5 years ago
leave_group_request.go transfer support kafka (#227) 5 years ago
leave_group_response.go transfer support kafka (#227) 5 years ago
length_field.go transfer support kafka (#227) 5 years ago
list_groups_request.go transfer support kafka (#227) 5 years ago
list_groups_response.go transfer support kafka (#227) 5 years ago
list_partition_reassignments_request.go transfer support kafka (#227) 5 years ago
list_partition_reassignments_response.go transfer support kafka (#227) 5 years ago
message.go transfer support kafka (#227) 5 years ago
message_set.go transfer support kafka (#227) 5 years ago
metadata_request.go transfer support kafka (#227) 5 years ago
metadata_response.go transfer support kafka (#227) 5 years ago
metrics.go transfer support kafka (#227) 5 years ago
mockbroker.go transfer support kafka (#227) 5 years ago
mockkerberos.go transfer support kafka (#227) 5 years ago
mockresponses.go transfer support kafka (#227) 5 years ago
offset_commit_request.go transfer support kafka (#227) 5 years ago
offset_commit_response.go transfer support kafka (#227) 5 years ago
offset_fetch_request.go transfer support kafka (#227) 5 years ago
offset_fetch_response.go transfer support kafka (#227) 5 years ago
offset_manager.go transfer support kafka (#227) 5 years ago
offset_request.go transfer support kafka (#227) 5 years ago
offset_response.go transfer support kafka (#227) 5 years ago
packet_decoder.go transfer support kafka (#227) 5 years ago
packet_encoder.go transfer support kafka (#227) 5 years ago
partitioner.go transfer support kafka (#227) 5 years ago
prep_encoder.go transfer support kafka (#227) 5 years ago
produce_request.go transfer support kafka (#227) 5 years ago
produce_response.go transfer support kafka (#227) 5 years ago
produce_set.go transfer support kafka (#227) 5 years ago
real_decoder.go transfer support kafka (#227) 5 years ago
real_encoder.go transfer support kafka (#227) 5 years ago
record.go transfer support kafka (#227) 5 years ago
record_batch.go transfer support kafka (#227) 5 years ago
records.go transfer support kafka (#227) 5 years ago
request.go transfer support kafka (#227) 5 years ago
response_header.go transfer support kafka (#227) 5 years ago
sarama.go transfer support kafka (#227) 5 years ago
sasl_authenticate_request.go transfer support kafka (#227) 5 years ago
sasl_authenticate_response.go transfer support kafka (#227) 5 years ago
sasl_handshake_request.go transfer support kafka (#227) 5 years ago
sasl_handshake_response.go transfer support kafka (#227) 5 years ago
sticky_assignor_user_data.go transfer support kafka (#227) 5 years ago
sync_group_request.go transfer support kafka (#227) 5 years ago
sync_group_response.go transfer support kafka (#227) 5 years ago
sync_producer.go transfer support kafka (#227) 5 years ago
timestamp.go transfer support kafka (#227) 5 years ago
txn_offset_commit_request.go transfer support kafka (#227) 5 years ago
txn_offset_commit_response.go transfer support kafka (#227) 5 years ago
utils.go transfer support kafka (#227) 5 years ago
zstd.go transfer support kafka (#227) 5 years ago

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.12 through 1.14, and Kafka 2.1 through 2.4, 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