|
.gitignore
|
11f0f9f698
better test
|
12 роки тому |
|
.travis.yml
|
e44cb688da
Add basic Travis config file
|
12 роки тому |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
12 роки тому |
|
README.md
|
8423f8cfeb
Tweak README
|
12 роки тому |
|
broker.go
|
24faa7d6f3
use net.SplitHostPort instead of strings.Split
|
12 роки тому |
|
broker_test.go
|
2f5cf8fd16
Fixed remaining test.
|
12 роки тому |
|
client.go
|
ba9974ffb1
Add PanicHandler
|
12 роки тому |
|
client_test.go
|
8f7144a7ed
wip
|
12 роки тому |
|
consumer.go
|
ba9974ffb1
Add PanicHandler
|
12 роки тому |
|
consumer_test.go
|
8f7144a7ed
wip
|
12 роки тому |
|
crc32_field.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
encoder_decoder.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
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
|
12 роки тому |
|
fetch_response.go
|
5509b4a29c
wip
|
12 роки тому |
|
fetch_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
length_field.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
message.go
|
fe223908f6
Compression codec is only two bits, not three.
|
12 роки тому |
|
message_set.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
message_test.go
|
901b907636
Revert "Compression codec is high three bits, not low"
|
12 роки тому |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
metadata_response.go
|
8f7144a7ed
wip
|
12 роки тому |
|
metadata_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
mockbroker.go
|
2bad7afe8f
Better error messages
|
12 роки тому |
|
offset_commit_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
offset_commit_request_test.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
offset_commit_response.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
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
|
12 роки тому |
|
offset_fetch_response.go
|
5509b4a29c
wip
|
12 роки тому |
|
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
|
12 роки тому |
|
offset_response.go
|
5509b4a29c
wip
|
12 роки тому |
|
offset_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
12 роки тому |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
12 роки тому |
|
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.
|
12 роки тому |
|
prep_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
12 роки тому |
|
produce_message.go
|
f6ca051218
RetryLimit in producer shouldn't be configurable.
|
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
|
5509b4a29c
wip
|
12 роки тому |
|
produce_response_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 роки тому |
|
producer.go
|
f6ca051218
RetryLimit in producer shouldn't be configurable.
|
12 роки тому |
|
producer_test.go
|
7fe4be2f64
remove MaxDeliveryRetries from test file
|
12 роки тому |
|
real_decoder.go
|
0f5cff6a9a
Return a decoding error for negative array lengths
|
12 роки тому |
|
real_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
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
|
ba9974ffb1
Add PanicHandler
|
12 роки тому |
|
utils.go
|
8db429b9dd
Fix panic handler bug (#52)
|
12 роки тому |
Burke Libbey