|
vagrant
|
f88167c1ae
Use the -daemon command line argument when starting zookeeper and kafka.
|
11 years ago |
|
.gitignore
|
d3bc825c36
Add Vagrantfile, and provisioning scripts that set up a working 5-node cluster.
|
11 years ago |
|
.travis.yml
|
029db836cf
Re-enable errcheck
|
11 years ago |
|
CONTRIBUTING.md
|
6aacbb7d86
Some additions
|
11 years ago |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
12 years ago |
|
README.md
|
4b5803fe4b
Add 1.4 support to readme
|
11 years ago |
|
Vagrantfile
|
6f2b60a051
Give it more memory by default
|
11 years ago |
|
broker.go
|
9d71abeed0
Make Broker.Open truly non-blocking
|
11 years ago |
|
broker_test.go
|
91a706483c
Unexport mockbroker.
|
11 years ago |
|
client.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
client_test.go
|
91a706483c
Unexport mockbroker.
|
11 years ago |
|
consumer.go
|
cc01cb4093
Merge pull request #303 from Shopify/split_consumer_events_channel
|
11 years ago |
|
consumer_metadata_request.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 years ago |
|
consumer_metadata_request_test.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 years ago |
|
consumer_metadata_response.go
|
e91bb557fd
golint: use CoordinatorID instead of CoordinatorId as variable name.
|
11 years ago |
|
consumer_metadata_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
consumer_test.go
|
91a706483c
Unexport mockbroker.
|
11 years ago |
|
crc32_field.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
encoder_decoder.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
errors.go
|
9d71abeed0
Make Broker.Open truly non-blocking
|
11 years ago |
|
fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 years ago |
|
fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 years ago |
|
fetch_response.go
|
75c8106b0b
Preparatory steps for the new consumer
|
11 years ago |
|
fetch_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
functional_test.go
|
e01d7b5b70
Merge pull request #304 from Shopify/producer_consumer_consistency
|
11 years ago |
|
length_field.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
message.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
message_set.go
|
2018fd405e
Prefix error variables with Err
|
11 years ago |
|
message_test.go
|
9675a91962
Added Gzip test. Simplified a little.
|
12 years ago |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
12 years ago |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
12 years ago |
|
metadata_response.go
|
d33e005ce0
Implement Client.WritablePartitions
|
11 years ago |
|
metadata_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
mockbroker.go
|
e571a38ded
Now that mockbroker is private we don't need testState
|
11 years ago |
|
offset_commit_request.go
|
53093b7fa8
Update a few odds and ends to the latest spec
|
11 years ago |
|
offset_commit_request_test.go
|
53093b7fa8
Update a few odds and ends to the latest spec
|
11 years ago |
|
offset_commit_response.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
11 years ago |
|
offset_commit_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
offset_fetch_request.go
|
39823e3af9
Check some errors
|
11 years ago |
|
offset_fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 years ago |
|
offset_fetch_response.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
11 years ago |
|
offset_fetch_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
offset_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 years ago |
|
offset_request_test.go
|
4969d24fa1
kafka->sarama
|
12 years ago |
|
offset_response.go
|
39823e3af9
Check some errors
|
11 years ago |
|
offset_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
12 years ago |
|
packet_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
12 years ago |
|
partitioner.go
|
3020cf16c6
Rework Partition interface and usage
|
11 years ago |
|
partitioner_test.go
|
3020cf16c6
Rework Partition interface and usage
|
11 years ago |
|
prep_encoder.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
produce_request.go
|
0d17c78f48
producer: add warning about RequiredAcks>1
|
11 years ago |
|
produce_request_test.go
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
11 years ago |
|
produce_response.go
|
5509b4a29c
wip
|
12 years ago |
|
produce_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
producer.go
|
e01d7b5b70
Merge pull request #304 from Shopify/producer_consumer_consistency
|
11 years ago |
|
producer_test.go
|
91a706483c
Unexport mockbroker.
|
11 years ago |
|
real_decoder.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
real_encoder.go
|
39823e3af9
Check some errors
|
11 years ago |
|
request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 years ago |
|
request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 years ago |
|
response_header.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 years ago |
|
sarama.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
simple_producer.go
|
f4fc52188a
Naming changes in the producer to be consistent with the consumer.
|
11 years ago |
|
snappy.go
|
cabc1b4ffc
golint: use var block, and simply use a variable declaration to create a byteslice with a length of 0
|
11 years ago |
|
snappy_test.go
|
b5df04ed3e
Make snappy functions private
|
11 years ago |
|
utils.go
|
ea16443baa
Fix safeAsyncClose logging again
|
11 years ago |
Evan Huus
