|
.gitignore
|
11f0f9f698
better test
|
12 年 前 |
|
.travis.yml
|
2a5ab0515b
Simple functional test
|
11 年 前 |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
12 年 前 |
|
README.md
|
726fa7099e
Add travis and godoc badges to README
|
11 年 前 |
|
broker.go
|
5cbd22983e
doc tweaks suggested by golint
|
11 年 前 |
|
broker_test.go
|
113fd78e0a
Add BrokerConfig
|
11 年 前 |
|
client.go
|
65629827b8
Return better error when server returns no offsets
|
11 年 前 |
|
client_test.go
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
11 年 前 |
|
consumer.go
|
affb0b04e0
Only update the stored offset on successful events
|
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
|
48450d597d
Consumer Metadata fields no longer optional
|
11 年 前 |
|
consumer_metadata_response_test.go
|
48450d597d
Consumer Metadata fields no longer optional
|
11 年 前 |
|
consumer_test.go
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
11 年 前 |
|
crc32_field.go
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
12 年 前 |
|
encoder_decoder.go
|
00a4811e0d
DecodingError.Packet wasn't very useful
|
12 年 前 |
|
errors.go
|
15782aa08d
Address Evan's comments on the previous version. Add checks for Closed() to a few other locations including consumer.go.
|
11 年 前 |
|
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 年 前 |
|
functional_test.go
|
414f7d26e6
Close the producer inline instead of deferring it.
|
11 年 前 |
|
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
|
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
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
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
|
12 年 前 |
|
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.
|
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
|
d4ba4ed0bf
Make sure we always call errorCb in flushRequest
|
11 年 前 |
|
produce_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 年 前 |
|
produce_request_test.go
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
11 年 前 |
|
produce_response.go
|
5509b4a29c
wip
|
12 年 前 |
|
produce_response_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 年 前 |
|
producer.go
|
9eb8bcccd5
Disconnect the broker when it returns us certain errors
|
11 年 前 |
|
producer_test.go
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
11 年 前 |
|
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.
|
12 年 前 |
|
request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 年 前 |
|
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.
|
12 年 前 |
|
sarama.go
|
ba9974ffb1
Add PanicHandler
|
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 年 前 |
Evan Huus
