홈 탐색 도움말
가입하기 로그인
publics
/
sarama
0
0
포크 0
파일 이슈 0 풀 리퀘스트 0 위키

설명 없음

트리: b65a39b735
브랜치 태그
sarama
Liu Cong b65a39b735 Update error of ReplicaNotAvailable description 12 년 전
.gitignore 11f0f9f698 better test 12 년 전
.travis.yml 2a5ab0515b Simple functional test 12 년 전
MIT-LICENSE 86b4691cdd Add license information 13 년 전
README.md 726fa7099e Add travis and godoc badges to README 12 년 전
broker.go 69c214b231 Make the initial dial timeout configurable 12 년 전
broker_test.go 113fd78e0a Add BrokerConfig 12 년 전
client.go 65629827b8 Return better error when server returns no offsets 12 년 전
client_test.go 53701a953d Make mockbroker's ID an int32 to avoid a boatload of casts 12 년 전
consumer.go affb0b04e0 Only update the stored offset on successful events 12 년 전
consumer_metadata_request.go 9520ed2cbd Implement consumer metadata request/response pair 12 년 전
consumer_metadata_request_test.go 9520ed2cbd Implement consumer metadata request/response pair 12 년 전
consumer_metadata_response.go 48450d597d Consumer Metadata fields no longer optional 12 년 전
consumer_metadata_response_test.go 48450d597d Consumer Metadata fields no longer optional 12 년 전
consumer_test.go 53701a953d Make mockbroker's ID an int32 to avoid a boatload of casts 12 년 전
crc32_field.go 34956b2be3 More informative logging around DecodingError, and bumped max msg size 12 년 전
encoder_decoder.go 396afc57f0 Configurable hard limit on the max size of requests 12 년 전
errors.go b65a39b735 Update error of ReplicaNotAvailable description 12 년 전
fetch_request.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
fetch_request_test.go 4969d24fa1 kafka->sarama 13 년 전
fetch_response.go 5509b4a29c wip 12 년 전
fetch_response_test.go b08596183c Flatten nested ifs with DeMorgan. 13 년 전
functional_test.go 414f7d26e6 Close the producer inline instead of deferring it. 12 년 전
length_field.go 34956b2be3 More informative logging around DecodingError, and bumped max msg size 12 년 전
message.go 9675a91962 Added Gzip test. Simplified a little. 12 년 전
message_set.go b1a73257c4 Allow to decode snappy streams 12 년 전
message_test.go 9675a91962 Added Gzip test. Simplified a little. 12 년 전
metadata_request.go 4969d24fa1 kafka->sarama 13 년 전
metadata_request_test.go 4969d24fa1 kafka->sarama 13 년 전
metadata_response.go 8f7144a7ed wip 12 년 전
metadata_response_test.go b08596183c Flatten nested ifs with DeMorgan. 13 년 전
mockbroker.go 53701a953d Make mockbroker's ID an int32 to avoid a boatload of casts 12 년 전
offset_commit_request.go 53093b7fa8 Update a few odds and ends to the latest spec 12 년 전
offset_commit_request_test.go 53093b7fa8 Update a few odds and ends to the latest spec 12 년 전
offset_commit_response.go aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1 12 년 전
offset_commit_response_test.go aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1 12 년 전
offset_fetch_request.go aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1 12 년 전
offset_fetch_request_test.go 4969d24fa1 kafka->sarama 13 년 전
offset_fetch_response.go aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1 12 년 전
offset_fetch_response_test.go aa133ab822 Fix offset commit/fetch compatibility with kafka 0.8.1 12 년 전
offset_request.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
offset_request_test.go 4969d24fa1 kafka->sarama 13 년 전
offset_response.go 5509b4a29c wip 12 년 전
offset_response_test.go b08596183c Flatten nested ifs with DeMorgan. 13 년 전
packet_decoder.go 4969d24fa1 kafka->sarama 13 년 전
packet_encoder.go 2f5cf8fd16 Fixed remaining test. 12 년 전
partitioner.go 2e9d4aa756 serialize HashPartitioner and RoundRobinPartitioner 12 년 전
partitioner_test.go f8f6c2a832 Fix HashPartitioner returning negative partitions. 13 년 전
prep_encoder.go 2f5cf8fd16 Fixed remaining test. 12 년 전
produce_message.go d4ba4ed0bf Make sure we always call errorCb in flushRequest 12 년 전
produce_request.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
produce_request_test.go 2bae192c12 Use time.Duration values consistently in *Config types. 12 년 전
produce_response.go 5509b4a29c wip 12 년 전
produce_response_test.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
producer.go 396afc57f0 Configurable hard limit on the max size of requests 12 년 전
producer_test.go 53701a953d Make mockbroker's ID an int32 to avoid a boatload of casts 12 년 전
real_decoder.go 34956b2be3 More informative logging around DecodingError, and bumped max msg size 12 년 전
real_encoder.go 2f5cf8fd16 Fixed remaining test. 12 년 전
request.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
request_test.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
response_header.go 34956b2be3 More informative logging around DecodingError, and bumped max msg size 12 년 전
response_header_test.go 893044d278 Fix Golint errors, except for all the missing comments. 13 년 전
sarama.go 396afc57f0 Configurable hard limit on the max size of requests 12 년 전
snappy.go 7664076559 Added support for snappy stream decoding 12 년 전
snappy_test.go 7664076559 Added support for snappy stream decoding 12 년 전
utils.go 8db429b9dd Fix panic handler bug (#52) 12 년 전

README.md

sarama

Build Status GoDoc

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

There is a google group for discussion

It is compatible with Go 1.1, 1.2, and 1.3 (which means go vet on 1.2 or 1.3 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.

Other related links: