Skip to content
/ sarama Public
forked from IBM/sarama

Sarama is a Go library for Apache Kafka 0.8

License

MIT license
0 stars 1.8k forks Branches Tags Activity
Star
Notifications You must be signed in to change notification settings

talbright/sarama

BranchesTags
 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

403 Commits
.gitignore
.gitignore
 
 
.travis.yml
.travis.yml
 
 
MIT-LICENSE
MIT-LICENSE
 
 
README.md
README.md
 
 
broker.go
broker.go
 
 
broker_test.go
broker_test.go
 
 
client.go
client.go
 
 
client_test.go
client_test.go
 
 
consumer.go
consumer.go
 
 
consumer_test.go
consumer_test.go
 
 
crc32_field.go
crc32_field.go
 
 
encoder_decoder.go
encoder_decoder.go
 
 
errors.go
errors.go
 
 
fetch_request.go
fetch_request.go
 
 
fetch_request_test.go
fetch_request_test.go
 
 
fetch_response.go
fetch_response.go
 
 
fetch_response_test.go
fetch_response_test.go
 
 
length_field.go
length_field.go
 
 
message.go
message.go
 
 
message_set.go
message_set.go
 
 
message_test.go
message_test.go
 
 
metadata_request.go
metadata_request.go
 
 
metadata_request_test.go
metadata_request_test.go
 
 
metadata_response.go
metadata_response.go
 
 
metadata_response_test.go
metadata_response_test.go
 
 
mockbroker.go
mockbroker.go
 
 
offset_commit_request.go
offset_commit_request.go
 
 
offset_commit_request_test.go
offset_commit_request_test.go
 
 
offset_commit_response.go
offset_commit_response.go
 
 
offset_commit_response_test.go
offset_commit_response_test.go
 
 
offset_fetch_request.go
offset_fetch_request.go
 
 
offset_fetch_request_test.go
offset_fetch_request_test.go
 
 
offset_fetch_response.go
offset_fetch_response.go
 
 
offset_fetch_response_test.go
offset_fetch_response_test.go
 
 
offset_request.go
offset_request.go
 
 
offset_request_test.go
offset_request_test.go
 
 
offset_response.go
offset_response.go
 
 
offset_response_test.go
offset_response_test.go
 
 
packet_decoder.go
packet_decoder.go
 
 
packet_encoder.go
packet_encoder.go
 
 
partitioner.go
partitioner.go
 
 
partitioner_test.go
partitioner_test.go
 
 
prep_encoder.go
prep_encoder.go
 
 
produce_message.go
produce_message.go
 
 
produce_request.go
produce_request.go
 
 
produce_request_test.go
produce_request_test.go
 
 
produce_response.go
produce_response.go
 
 
produce_response_test.go
produce_response_test.go
 
 
producer.go
producer.go
 
 
producer_test.go
producer_test.go
 
 
real_decoder.go
real_decoder.go
 
 
real_encoder.go
real_encoder.go
 
 
request.go
request.go
 
 
request_test.go
request_test.go
 
 
response_header.go
response_header.go
 
 
response_header_test.go
response_header_test.go
 
 
sarama.go
sarama.go
 
 
snappy.go
snappy.go
 
 
snappy_test.go
snappy_test.go
 
 
utils.go
utils.go
 
 

Repository files navigation

sarama

Sarama is an MIT-licensed Go client library for Apache Kafka 0.8 (and later).

Documentation is available via godoc at https://godoc.org/github.com/Shopify/sarama

It is compatible with Go 1.0 and 1.1 (which means go vet on 1.1 will return some suggestions that we are ignoring for the sake of compatibility with 1.0).

A word of warning: the API is not 100% stable yet. It won't change much (in particular the low-level Broker and Request/Response objects could probably be considered frozen) but there may be the occasional parameter added or function renamed. As far as semantic versioning is concerned, we haven't quite hit 1.0.0 yet. It is absolutely stable enough to use, just expect that you might have to tweak things when you update to a newer version.

Other related links:

About

Sarama is a Go library for Apache Kafka 0.8

Resources

Readme

License

MIT license
Activity

Stars

0 stars

Watchers

1 watching

Forks

0 forks
Report repository

Releases

No releases published

Packages

No packages published