|
vagrant
|
a11b33f6d1
Let brokers connect to *all* zookeepers
|
11 роки тому |
|
.gitignore
|
d3bc825c36
Add Vagrantfile, and provisioning scripts that set up a working 5-node cluster.
|
11 роки тому |
|
.travis.yml
|
47d503b1c8
Add -race to test command
|
11 роки тому |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
13 роки тому |
|
README.md
|
e3d987ba98
README tweaks
|
12 роки тому |
|
Vagrantfile
|
6f2b60a051
Give it more memory by default
|
11 роки тому |
|
broker.go
|
69c214b231
Make the initial dial timeout configurable
|
12 роки тому |
|
broker_test.go
|
113fd78e0a
Add BrokerConfig
|
12 роки тому |
|
client.go
|
e594cf0ae1
client: close backgroundMetadataUpdater faster
|
11 роки тому |
|
client_test.go
|
430eaee5b4
Actually check the return from Close in our tests
|
11 роки тому |
|
consumer.go
|
39a066ae3d
consumer: add unit test
|
11 роки тому |
|
consumer_metadata_request.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
12 роки тому |
|
consumer_metadata_request_test.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
12 роки тому |
|
consumer_metadata_response.go
|
48450d597d
Consumer Metadata fields no longer optional
|
12 роки тому |
|
consumer_metadata_response_test.go
|
48450d597d
Consumer Metadata fields no longer optional
|
12 роки тому |
|
consumer_test.go
|
430eaee5b4
Actually check the return from Close in our tests
|
11 роки тому |
|
crc32_field.go
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
12 роки тому |
|
encoder_decoder.go
|
396afc57f0
Configurable hard limit on the max size of requests
|
12 роки тому |
|
errors.go
|
5237f6fb5e
Remove now-unused error type
|
11 роки тому |
|
fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
13 роки тому |
|
fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
fetch_response.go
|
39a066ae3d
consumer: add unit test
|
11 роки тому |
|
fetch_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
13 роки тому |
|
functional_test.go
|
eb42926dd4
Move successes to its own channel
|
11 роки тому |
|
length_field.go
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
12 роки тому |
|
message.go
|
0a9f80b431
Merge pull request #171 from Shopify/hide-snappy-funcs
|
11 роки тому |
|
message_set.go
|
39823e3af9
Check some errors
|
11 роки тому |
|
message_test.go
|
9675a91962
Added Gzip test. Simplified a little.
|
12 роки тому |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
metadata_response.go
|
8f7144a7ed
wip
|
12 роки тому |
|
metadata_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
13 роки тому |
|
mockbroker.go
|
f77e4b63b8
Fix test raciness
|
11 роки тому |
|
offset_commit_request.go
|
53093b7fa8
Update a few odds and ends to the latest spec
|
12 роки тому |
|
offset_commit_request_test.go
|
53093b7fa8
Update a few odds and ends to the latest spec
|
12 роки тому |
|
offset_commit_response.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
12 роки тому |
|
offset_commit_response_test.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
12 роки тому |
|
offset_fetch_request.go
|
39823e3af9
Check some errors
|
11 роки тому |
|
offset_fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_fetch_response.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
12 роки тому |
|
offset_fetch_response_test.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
12 роки тому |
|
offset_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
13 роки тому |
|
offset_request_test.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
offset_response.go
|
39823e3af9
Check some errors
|
11 роки тому |
|
offset_response_test.go
|
b08596183c
Flatten nested ifs with DeMorgan.
|
13 роки тому |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
13 роки тому |
|
packet_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
12 роки тому |
|
partitioner.go
|
237cfb5380
Check more errors
|
11 роки тому |
|
partitioner_test.go
|
6aca6498e2
Implement ConstantPartitioner
|
11 роки тому |
|
prep_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
12 роки тому |
|
produce_request.go
|
d5448f1b9a
New Producer design
|
11 роки тому |
|
produce_request_test.go
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
12 роки тому |
|
produce_response.go
|
5509b4a29c
wip
|
12 роки тому |
|
produce_response_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
13 роки тому |
|
producer.go
|
c115b651d2
prod: explicitly log every state change
|
11 роки тому |
|
producer_test.go
|
f77e4b63b8
Fix test raciness
|
11 роки тому |
|
real_decoder.go
|
34956b2be3
More informative logging around DecodingError, and bumped max msg size
|
12 роки тому |
|
real_encoder.go
|
39823e3af9
Check some errors
|
11 роки тому |
|
request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
13 роки тому |
|
request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
13 роки тому |
|
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.
|
13 роки тому |
|
sarama.go
|
0a2774565c
make logger an interface
|
11 роки тому |
|
simple_producer.go
|
f72aa709c9
Add a mutex to SimpleProducer.SendMessage
|
11 роки тому |
|
snappy.go
|
6bdcabb23e
Remove a dead import from the snappy code
|
11 роки тому |
|
snappy_test.go
|
b5df04ed3e
Make snappy functions private
|
11 роки тому |
|
utils.go
|
87f20fcd6d
Make withRecover raceless for real
|
11 роки тому |
Willem van Bergen
