• Home
  • History
  • Annotate
Name Date Size #Lines LOC

..03-May-2022-

.github/H27-Sep-2018-5333

examples/H27-Sep-2018-379272

mocks/H27-Sep-2018-1,345932

tools/H27-Sep-2018-488386

vagrant/H27-Sep-2018-357250

.gitignoreH A D27-Sep-2018294 2821

.travis.ymlH A D27-Sep-2018740 3730

CHANGELOG.mdH A D27-Sep-201826.9 KiB594504

LICENSEH A D27-Sep-20181 KiB2117

MakefileH A D27-Sep-2018761 3121

README.mdH A D27-Sep-20182.1 KiB4029

VagrantfileH A D27-Sep-2018528 2114

acl_bindings.goH A D27-Sep-20182.1 KiB12094

acl_create_request.goH A D27-Sep-20181.3 KiB7760

acl_create_request_test.goH A D27-Sep-2018678 3530

acl_create_response.goH A D27-Sep-20181.7 KiB8968

acl_create_response_test.goH A D27-Sep-2018761 4234

acl_delete_request.goH A D27-Sep-2018859 4938

acl_delete_request_test.goH A D27-Sep-20181.4 KiB7059

acl_delete_response.goH A D27-Sep-20182.9 KiB156124

acl_delete_response_test.goH A D27-Sep-2018856 3934

acl_describe_request.goH A D27-Sep-2018490 2619

acl_describe_request_test.goH A D27-Sep-2018684 3630

acl_describe_response.goH A D27-Sep-20181.5 KiB8164

acl_describe_response_test.goH A D27-Sep-2018937 4641

acl_filter.goH A D27-Sep-20181.2 KiB6251

acl_types.goH A D27-Sep-20181.5 KiB4333

add_offsets_to_txn_request.goH A D27-Sep-20181,022 5342

add_offsets_to_txn_request_test.goH A D27-Sep-2018421 2419

add_offsets_to_txn_response.goH A D27-Sep-2018826 4535

add_offsets_to_txn_response_test.goH A D27-Sep-2018342 2318

add_partitions_to_txn_request.goH A D27-Sep-20181.5 KiB7763

add_partitions_to_txn_request_test.goH A D27-Sep-2018543 2823

add_partitions_to_txn_response.goH A D27-Sep-20182 KiB10987

add_partitions_to_txn_response_test.goH A D27-Sep-2018585 3227

admin.goH A D27-Sep-201810.4 KiB383257

admin_test.goH A D27-Sep-201811.8 KiB502417

alter_configs_request.goH A D27-Sep-20182.2 KiB12199

alter_configs_request_test.goH A D27-Sep-20181.9 KiB8776

alter_configs_response.goH A D27-Sep-20181.8 KiB9676

alter_configs_response_test.goH A D27-Sep-2018898 4639

api_versions_request.goH A D27-Sep-2018426 2518

api_versions_request_test.goH A D27-Sep-2018241 1510

api_versions_response.goH A D27-Sep-20181.6 KiB8870

api_versions_response_test.goH A D27-Sep-2018871 3328

async_producer.goH A D27-Sep-201825.7 KiB933691

async_producer_test.goH A D27-Sep-201824.1 KiB846680

balance_strategy.goH A D27-Sep-20183.9 KiB13085

balance_strategy_test.goH A D27-Sep-20183.1 KiB10393

broker.goH A D27-Sep-201822.4 KiB885670

broker_test.goH A D27-Sep-20189.3 KiB359315

client.goH A D27-Sep-201826.2 KiB877617

client_test.goH A D27-Sep-201818.3 KiB662508

client_tls_test.goH A D27-Sep-20184.8 KiB207184

config.goH A D27-Sep-201824.3 KiB564307

config_resource_type.goH A D27-Sep-2018472 1610

config_test.goH A D27-Sep-20186.5 KiB256227

consumer.goH A D27-Sep-201824 KiB808595

consumer_group.goH A D27-Sep-201821.4 KiB775528

consumer_group_members.goH A D27-Sep-20181.7 KiB9574

consumer_group_members_test.goH A D27-Sep-20181.9 KiB7465

consumer_group_test.goH A D27-Sep-20181.4 KiB5944

consumer_metadata_request.goH A D27-Sep-2018741 3427

consumer_metadata_request_test.goH A D27-Sep-2018627 2418

consumer_metadata_response.goH A D27-Sep-20181.6 KiB7860

consumer_metadata_response_test.goH A D27-Sep-20181.1 KiB4537

consumer_test.goH A D27-Sep-201830.1 KiB1,037782

crc32_field.goH A D27-Sep-20181.4 KiB7056

create_partitions_request.goH A D27-Sep-20182.2 KiB12297

create_partitions_request_test.goH A D27-Sep-20181.1 KiB5143

create_partitions_response.goH A D27-Sep-20181.9 KiB9575

create_partitions_response_test.goH A D27-Sep-20181.4 KiB5345

create_topics_request.goH A D27-Sep-20183.2 KiB175146

create_topics_request_test.goH A D27-Sep-20181 KiB5142

create_topics_response.goH A D27-Sep-20182 KiB11392

create_topics_response_test.goH A D27-Sep-2018905 5342

delete_groups_request.goH A D27-Sep-2018599 3123

delete_groups_request_test.goH A D27-Sep-2018811 3526

delete_groups_response.goH A D27-Sep-20181.3 KiB7157

delete_groups_response_test.goH A D27-Sep-20181.5 KiB5849

delete_records_request.goH A D27-Sep-20182.6 KiB127103

delete_records_request_test.goH A D27-Sep-2018614 3732

delete_records_response.goH A D27-Sep-20183.3 KiB159129

delete_records_response_test.goH A D27-Sep-2018741 4035

delete_topics_request.goH A D27-Sep-2018903 4940

delete_topics_request_test.goH A D27-Sep-2018611 3427

delete_topics_response.goH A D27-Sep-20181.4 KiB7963

delete_topics_response_test.goH A D27-Sep-2018592 3729

describe_configs_request.goH A D27-Sep-20181.6 KiB9274

describe_configs_request_test.goH A D27-Sep-20182.2 KiB9178

describe_configs_response.goH A D27-Sep-20183.2 KiB189155

describe_configs_response_test.goH A D27-Sep-20181.2 KiB6154

describe_groups_request.goH A D27-Sep-2018613 3123

describe_groups_request_test.goH A D27-Sep-2018833 3526

describe_groups_response.goH A D27-Sep-20183.8 KiB188157

describe_groups_response_test.goH A D27-Sep-20182.7 KiB9281

dev.ymlH A D27-Sep-2018113 118

encoder_decoder.goH A D27-Sep-20181.9 KiB9063

end_txn_request.goH A D27-Sep-2018950 5140

end_txn_request_test.goH A D27-Sep-2018350 2419

end_txn_response.goH A D27-Sep-2018772 4535

end_txn_response_test.goH A D27-Sep-2018310 2318

errors.goH A D27-Sep-201814.7 KiB282227

fetch_request.goH A D27-Sep-20183.6 KiB171152

fetch_request_test.goH A D27-Sep-20181.5 KiB4939

fetch_response.goH A D27-Sep-20187.9 KiB397327

fetch_response_test.goH A D27-Sep-20189.3 KiB332292

find_coordinator_request.goH A D27-Sep-20181.1 KiB6248

find_coordinator_request_test.goH A D27-Sep-2018733 3426

find_coordinator_response.goH A D27-Sep-20181.7 KiB9374

find_coordinator_response_test.goH A D27-Sep-20181.9 KiB8480

functional_client_test.goH A D27-Sep-20182.1 KiB9172

functional_consumer_group_test.goH A D27-Sep-201810.2 KiB419331

functional_consumer_test.goH A D27-Sep-20186.8 KiB227171

functional_offset_manager_test.goH A D27-Sep-2018938 4837

functional_producer_test.goH A D27-Sep-201810.5 KiB324255

functional_test.goH A D27-Sep-20183.4 KiB149125

heartbeat_request.goH A D27-Sep-2018830 4837

heartbeat_request_test.goH A D27-Sep-2018441 2217

heartbeat_response.goH A D27-Sep-2018536 3325

heartbeat_response_test.goH A D27-Sep-2018397 1914

init_producer_id_request.goH A D27-Sep-2018878 4433

init_producer_id_request_test.goH A D27-Sep-2018528 3224

init_producer_id_response.goH A D27-Sep-20181 KiB5643

init_producer_id_response_test.goH A D27-Sep-2018650 3830

join_group_request.goH A D27-Sep-20183.4 KiB164140

join_group_request_test.goH A D27-Sep-20183 KiB8475

join_group_response.goH A D27-Sep-20182.4 KiB136111

join_group_response_test.goH A D27-Sep-20185.5 KiB173160

leave_group_request.goH A D27-Sep-2018711 4132

leave_group_request_test.goH A D27-Sep-2018347 2015

leave_group_response.goH A D27-Sep-2018548 3325

leave_group_response_test.goH A D27-Sep-2018696 2519

length_field.goH A D27-Sep-20181.8 KiB8364

list_groups_request.goH A D27-Sep-2018419 2518

list_groups_request_test.goH A D27-Sep-2018148 85

list_groups_response.goH A D27-Sep-20181.1 KiB7056

list_groups_response_test.goH A D27-Sep-20181.4 KiB5950

message.goH A D27-Sep-20185 KiB224182

message_set.goH A D27-Sep-20182.2 KiB10987

message_test.goH A D27-Sep-20186.7 KiB197175

metadata_request.goH A D27-Sep-20181.5 KiB8980

metadata_request_test.goH A D27-Sep-20182.2 KiB7758

metadata_response.goH A D27-Sep-20185.3 KiB322263

metadata_response_test.goH A D27-Sep-20188.9 KiB291241

metrics.goH A D27-Sep-20182.1 KiB5233

metrics_test.goH A D27-Sep-20185.1 KiB173142

mockbroker.goH A D27-Sep-20189.3 KiB331237

mockresponses.goH A D27-Sep-201819.7 KiB728615

offset_commit_request.goH A D27-Sep-20185.1 KiB205168

offset_commit_request_test.goH A D27-Sep-20182.9 KiB9177

offset_commit_response.goH A D27-Sep-20181.7 KiB8672

offset_commit_response_test.goH A D27-Sep-2018606 2518

offset_fetch_request.goH A D27-Sep-20181.7 KiB8272

offset_fetch_request_test.goH A D27-Sep-2018875 3224

offset_fetch_response.goH A D27-Sep-20182.8 KiB144118

offset_fetch_response_test.goH A D27-Sep-2018606 2316

offset_manager.goH A D27-Sep-201814.7 KiB573415

offset_manager_test.goH A D27-Sep-201811.4 KiB422322

offset_request.goH A D27-Sep-20182.6 KiB133116

offset_request_test.goH A D27-Sep-20181.1 KiB4435

offset_response.goH A D27-Sep-20183.2 KiB175126

offset_response_test.goH A D27-Sep-20183.1 KiB11283

packet_decoder.goH A D27-Sep-20182.3 KiB6132

packet_encoder.goH A D27-Sep-20182.3 KiB6632

partitioner.goH A D27-Sep-20187.3 KiB218143

partitioner_test.goH A D27-Sep-20187.6 KiB284226

prep_encoder.goH A D27-Sep-20182.7 KiB154121

produce_request.goH A D27-Sep-20187.2 KiB253212

produce_request_test.goH A D27-Sep-20182.7 KiB10791

produce_response.goH A D27-Sep-20183.6 KiB184152

produce_response_test.goH A D27-Sep-20183.9 KiB129110

produce_set.goH A D27-Sep-20187.7 KiB253202

produce_set_test.goH A D27-Sep-20185.8 KiB256217

real_decoder.goH A D27-Sep-20186.3 KiB325266

real_encoder.goH A D27-Sep-20182.8 KiB157123

record.goH A D27-Sep-20182.1 KiB11493

record_batch.goH A D27-Sep-20185.6 KiB269231

record_test.goH A D27-Sep-20188.2 KiB293284

records.goH A D27-Sep-20184.3 KiB195165

records_test.goH A D27-Sep-20182.5 KiB144125

request.goH A D27-Sep-20183.1 KiB150138

request_test.goH A D27-Sep-20183.3 KiB10686

response_header.goH A D27-Sep-2018437 2217

response_header_test.goH A D27-Sep-2018481 2217

sarama.goH A D27-Sep-20187.7 KiB10014

sasl_handshake_request.goH A D27-Sep-2018593 3425

sasl_handshake_request_test.goH A D27-Sep-2018308 1813

sasl_handshake_response.goH A D27-Sep-2018721 3929

sasl_handshake_response_test.goH A D27-Sep-2018598 2520

sync_group_request.goH A D27-Sep-20182 KiB10182

sync_group_request_test.goH A D27-Sep-2018975 3932

sync_group_response.goH A D27-Sep-2018862 4232

sync_group_response_test.goH A D27-Sep-20181.1 KiB4134

sync_producer.goH A D27-Sep-20184.6 KiB150101

sync_producer_test.goH A D27-Sep-20184.8 KiB200166

timestamp.goH A D27-Sep-2018744 4130

txn_offset_commit_request.goH A D27-Sep-20182.6 KiB127107

txn_offset_commit_request_test.goH A D27-Sep-2018769 3631

txn_offset_commit_response.goH A D27-Sep-20181.5 KiB8467

txn_offset_commit_response_test.goH A D27-Sep-2018582 3227

utils.goH A D27-Sep-20185.2 KiB215165

utils_test.goH A D27-Sep-20181,012 4237

README.md

1sarama
2======
3
4[![GoDoc](https://godoc.org/github.com/Shopify/sarama?status.png)](https://godoc.org/github.com/Shopify/sarama)
5[![Build Status](https://travis-ci.org/Shopify/sarama.svg?branch=master)](https://travis-ci.org/Shopify/sarama)
6[![Coverage](https://codecov.io/gh/Shopify/sarama/branch/master/graph/badge.svg)](https://codecov.io/gh/Shopify/sarama)
7
8Sarama is an MIT-licensed Go client library for [Apache Kafka](https://kafka.apache.org/) version 0.8 (and later).
9
10### Getting started
11
12- API documentation and examples are available via [godoc](https://godoc.org/github.com/Shopify/sarama).
13- Mocks for testing are available in the [mocks](./mocks) subpackage.
14- The [examples](./examples) directory contains more elaborate example applications.
15- The [tools](./tools) directory contains command line tools that can be useful for testing, diagnostics, and instrumentation.
16
17You might also want to look at the [Frequently Asked Questions](https://github.com/Shopify/sarama/wiki/Frequently-Asked-Questions).
18
19### Compatibility and API stability
20
21Sarama provides a "2 releases + 2 months" compatibility guarantee: we support
22the two latest stable releases of Kafka and Go, and we provide a two month
23grace period for older releases. This means we currently officially support
24Go 1.8 through 1.11, and Kafka 1.0 through 2.0, although older releases are
25still likely to work.
26
27Sarama follows semantic versioning and provides API stability via the gopkg.in service.
28You can import a version with a guaranteed stable API via http://gopkg.in/Shopify/sarama.v1.
29A changelog is available [here](CHANGELOG.md).
30
31### Contributing
32
33* Get started by checking our [contribution guidelines](https://github.com/Shopify/sarama/blob/master/.github/CONTRIBUTING.md).
34* Read the [Sarama wiki](https://github.com/Shopify/sarama/wiki) for more
35  technical and design details.
36* The [Kafka Protocol Specification](https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol)
37  contains a wealth of useful information.
38* For more general issues, there is [a google group](https://groups.google.com/forum/#!forum/kafka-clients) for Kafka client developers.
39* If you have any questions, just ask!
40