설명 없음

416 커밋

Patrick Lucas af14c766f0 Fix two minor bugs in producer.go		11 년 전
.gitignore	11f0f9f698 better test	11 년 전
.travis.yml	386975c3dd Old kafka URL is dead, replace with new one	11 년 전
MIT-LICENSE	86b4691cdd Add license information	11 년 전
README.md	be6f649828 Drop pretense of support for Go 1.0	11 년 전
broker.go	be6f649828 Drop pretense of support for Go 1.0	11 년 전
broker_test.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
client.go	be6f649828 Drop pretense of support for Go 1.0	11 년 전
client_test.go	12297f18bd Fixed tests	11 년 전
consumer.go	be6f649828 Drop pretense of support for Go 1.0	11 년 전
consumer_test.go	be6f649828 Drop pretense of support for Go 1.0	11 년 전
crc32_field.go	34956b2be3 More informative logging around DecodingError, and bumped max msg size	11 년 전
encoder_decoder.go	00a4811e0d DecodingError.Packet wasn't very useful	11 년 전
errors.go	00a4811e0d DecodingError.Packet wasn't very useful	11 년 전
fetch_request.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
fetch_request_test.go	4969d24fa1 kafka->sarama	11 년 전
fetch_response.go	5509b4a29c wip	11 년 전
fetch_response_test.go	b08596183c Flatten nested ifs with DeMorgan.	11 년 전
length_field.go	34956b2be3 More informative logging around DecodingError, and bumped max msg size	11 년 전
message.go	9675a91962 Added Gzip test. Simplified a little.	11 년 전
message_set.go	b1a73257c4 Allow to decode snappy streams	11 년 전
message_test.go	9675a91962 Added Gzip test. Simplified a little.	11 년 전
metadata_request.go	4969d24fa1 kafka->sarama	11 년 전
metadata_request_test.go	4969d24fa1 kafka->sarama	11 년 전
metadata_response.go	8f7144a7ed wip	11 년 전
metadata_response_test.go	b08596183c Flatten nested ifs with DeMorgan.	11 년 전
mockbroker.go	be6f649828 Drop pretense of support for Go 1.0	11 년 전
offset_commit_request.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
offset_commit_request_test.go	4969d24fa1 kafka->sarama	11 년 전
offset_commit_response.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
offset_commit_response_test.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
offset_fetch_request.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
offset_fetch_request_test.go	4969d24fa1 kafka->sarama	11 년 전
offset_fetch_response.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
offset_fetch_response_test.go	aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1	11 년 전
offset_request.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
offset_request_test.go	4969d24fa1 kafka->sarama	11 년 전
offset_response.go	5509b4a29c wip	11 년 전
offset_response_test.go	b08596183c Flatten nested ifs with DeMorgan.	11 년 전
packet_decoder.go	4969d24fa1 kafka->sarama	11 년 전
packet_encoder.go	2f5cf8fd16 Fixed remaining test.	11 년 전
partitioner.go	2e9d4aa756 serialize HashPartitioner and RoundRobinPartitioner	11 년 전
partitioner_test.go	f8f6c2a832 Fix HashPartitioner returning negative partitions.	11 년 전
prep_encoder.go	2f5cf8fd16 Fixed remaining test.	11 년 전
produce_message.go	9d35a0c617 retried as a boolean rather than failures as an int	11 년 전
produce_request.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
produce_request_test.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
produce_response.go	5509b4a29c wip	11 년 전
produce_response_test.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
producer.go	af14c766f0 Fix two minor bugs in producer.go	11 년 전
producer_test.go	334af0e75e Fixed examples.	11 년 전
real_decoder.go	34956b2be3 More informative logging around DecodingError, and bumped max msg size	11 년 전
real_encoder.go	2f5cf8fd16 Fixed remaining test.	11 년 전
request.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
request_test.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
response_header.go	34956b2be3 More informative logging around DecodingError, and bumped max msg size	11 년 전
response_header_test.go	893044d278 Fix Golint errors, except for all the missing comments.	11 년 전
sarama.go	ba9974ffb1 Add PanicHandler	11 년 전
snappy.go	7664076559 Added support for snappy stream decoding	11 년 전
snappy_test.go	7664076559 Added support for snappy stream decoding	11 년 전
utils.go	8db429b9dd Fix panic handler bug (#52)	11 년 전

sarama

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

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

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

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.

README.md

sarama