|
.gitignore
|
11f0f9f698
better test
|
12 роки тому |
|
.travis.yml
|
e44cb688da
Add basic Travis config file
|
12 роки тому |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
13 роки тому |
|
README.md
|
8423f8cfeb
Tweak README
|
12 роки тому |
|
broker.go
|
3a0483dc2b
Allow configuration of per-broker concurrency.
|
12 роки тому |
|
broker_test.go
|
3a0483dc2b
Allow configuration of per-broker concurrency.
|
12 роки тому |
|
client.go
|
aa086bfe0b
Add empty topic error handling
|
12 роки тому |
|
client_test.go
|
d1bbdae1d5
Make Client.Leader() public.
|
12 роки тому |
|
consumer.go
|
3f1ee04b51
Add error handling for empty topics
|
12 роки тому |
|
consumer_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
crc32_field.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
encoder_decoder.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
errors.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
fetch_response.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
fetch_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
length_field.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
message.go
|
901b907636
Revert "Compression codec is high three bits, not low"
|
12 роки тому |
|
message_set.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
message_test.go
|
901b907636
Revert "Compression codec is high three bits, not low"
|
12 роки тому |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
metadata_response.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
metadata_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
offset_commit_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
offset_commit_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_commit_response.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_commit_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
offset_fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
offset_fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_fetch_response.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_fetch_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
offset_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
offset_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_response.go
|
2565bc81b7
Add an OffsetMethod that permits specifying other methods of determining the offset, such as querying the broker
|
12 роки тому |
|
offset_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
packet_encoder.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
partitioner.go
|
f8f6c2a832
Fix HashPartitioner returning negative partitions.
|
12 роки тому |
|
partitioner_test.go
|
f8f6c2a832
Fix HashPartitioner returning negative partitions.
|
12 роки тому |
|
prep_encoder.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
produce_message.go
|
4731510d8d
wip
|
12 роки тому |
|
produce_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
produce_request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
produce_response.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
produce_response_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
producer.go
|
f98386096e
wip
|
12 роки тому |
|
producer_test.go
|
f98386096e
wip
|
12 роки тому |
|
real_decoder.go
|
0f5cff6a9a
Return a decoding error for negative array lengths
|
12 роки тому |
|
real_encoder.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
response_header.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
sarama.go
|
3157a4b1f5
Improve logger documentation.
|
12 роки тому |
|
utils.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
Burke Libbey