|
.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
|
ac43305594
Add broker func for consumer metadata request
|
11 роки тому |
|
broker_test.go
|
ac43305594
Add broker func for consumer metadata request
|
11 роки тому |
|
client.go
|
be6f649828
Drop pretense of support for Go 1.0
|
11 роки тому |
|
client_test.go
|
12297f18bd
Fixed tests
|
11 роки тому |
|
consumer.go
|
b0c0c68111
Add topic and partition to ConsumerEvent struct
|
11 роки тому |
|
consumer_metadata_request.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 роки тому |
|
consumer_metadata_request_test.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 роки тому |
|
consumer_metadata_response.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 роки тому |
|
consumer_metadata_response_test.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
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
|
53093b7fa8
Update a few odds and ends to the latest spec
|
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
|
53093b7fa8
Update a few odds and ends to the latest spec
|
11 роки тому |
|
offset_commit_request_test.go
|
53093b7fa8
Update a few odds and ends to the latest spec
|
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 роки тому |
Willem van Bergen