|
examples
|
af448a6f24
Fix names as a_name to be aName
|
9 anos atrás |
|
mocks
|
5f78d90083
Add high water mark offset support to the consumer.
|
9 anos atrás |
|
tools
|
9008214b35
Rename topicConsumer tool to just consumer
|
9 anos atrás |
|
vagrant
|
30ddad94af
Make sure the toxiproxy path is based in the repository root
|
9 anos atrás |
|
.gitignore
|
d3bc825c36
Add Vagrantfile, and provisioning scripts that set up a working 5-node cluster.
|
10 anos atrás |
|
.travis.yml
|
06fd7d7b5b
Gimme expects 1.5 not 1.5.0
|
9 anos atrás |
|
CHANGELOG.md
|
4faee61999
Prep for v1.6
|
9 anos atrás |
|
CONTRIBUTING.md
|
6aacbb7d86
Some additions
|
10 anos atrás |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
11 anos atrás |
|
Makefile
|
44d2339061
Put a 60s limit on the test suite
|
9 anos atrás |
|
README.md
|
14024da87c
Add go 1.5 to build matrix, and mention support in README
|
9 anos atrás |
|
Vagrantfile
|
cf5665ab9a
Increase memory with vagrant virtualbox
|
9 anos atrás |
|
async_producer.go
|
765b3b4f7d
Clean up aggregator via helper methods
|
9 anos atrás |
|
async_producer_test.go
|
737294ce64
Fix the flakiest producer test
|
9 anos atrás |
|
broker.go
|
306db491eb
Fix two decoding bugs found by go-fuzz
|
9 anos atrás |
|
broker_test.go
|
0abdf8c4f0
Move the clientID into the config object
|
9 anos atrás |
|
client.go
|
e493c2606a
Update godoc for Client.Coordinator and Client.RefreshCoordinator
|
9 anos atrás |
|
client_test.go
|
1874f69e22
Shuffle seed brokers so we don't always connect to the first one provided
|
9 anos atrás |
|
config.go
|
46fa225867
A few minor offset-manager tweaks
|
9 anos atrás |
|
config_test.go
|
616ac5daa4
Unify configuration structures into config.go
|
9 anos atrás |
|
consumer.go
|
cdd80eb39a
Fix consumer race panic on close
|
9 anos atrás |
|
consumer_metadata_request.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
consumer_metadata_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
consumer_metadata_response.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
consumer_metadata_response_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
consumer_test.go
|
b26b6114e5
Address code inspection comments
|
9 anos atrás |
|
crc32_field.go
|
8fa523b125
Use an optimized crc32 library which is faster
|
9 anos atrás |
|
encoder_decoder.go
|
66411d8222
Cleanup a bunch more error formats
|
9 anos atrás |
|
errors.go
|
66411d8222
Cleanup a bunch more error formats
|
9 anos atrás |
|
fetch_request.go
|
4636efcdb8
Proof-of-concept exposing a kafka server API
|
9 anos atrás |
|
fetch_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
fetch_response.go
|
900e4f4595
Centralize and unify getSubset error checking
|
9 anos atrás |
|
fetch_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
9 anos atrás |
|
functional_client_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
9 anos atrás |
|
functional_consumer_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
9 anos atrás |
|
functional_offset_manager_test.go
|
e8c3c16e1a
Add a functional test for the offset manager.
|
9 anos atrás |
|
functional_producer_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
9 anos atrás |
|
functional_test.go
|
e8c3c16e1a
Add a functional test for the offset manager.
|
9 anos atrás |
|
length_field.go
|
66411d8222
Cleanup a bunch more error formats
|
9 anos atrás |
|
message.go
|
2594b8edd6
Fix and simplify message decoding
|
9 anos atrás |
|
message_set.go
|
2018fd405e
Prefix error variables with Err
|
9 anos atrás |
|
message_test.go
|
9675a91962
Added Gzip test. Simplified a little.
|
11 anos atrás |
|
metadata_request.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
metadata_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
metadata_response.go
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
9 anos atrás |
|
metadata_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
9 anos atrás |
|
mockbroker_test.go
|
2f9ed0e95b
Add History() method to mockbroker
|
9 anos atrás |
|
mockresponses_test.go
|
41ad0e456c
Fix tests
|
9 anos atrás |
|
offset_commit_request.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
offset_commit_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
offset_commit_response.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
offset_commit_response_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
offset_fetch_request.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
offset_fetch_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
offset_fetch_response.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
offset_fetch_response_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
offset_manager.go
|
e4cf5d402c
Fix offset-manager expiry timestamps to 'now'
|
9 anos atrás |
|
offset_manager_test.go
|
5109f975f5
OffsetManager: make initial offset configurable
|
9 anos atrás |
|
offset_request.go
|
4636efcdb8
Proof-of-concept exposing a kafka server API
|
9 anos atrás |
|
offset_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
offset_response.go
|
39823e3af9
Check some errors
|
10 anos atrás |
|
offset_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
9 anos atrás |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
11 anos atrás |
|
packet_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
11 anos atrás |
|
partitioner.go
|
1101246f70
Pass the topic to the partitioner constructor
|
9 anos atrás |
|
partitioner_test.go
|
faec514115
Add an example for different partitioning per topic.
|
9 anos atrás |
|
prep_encoder.go
|
66411d8222
Cleanup a bunch more error formats
|
9 anos atrás |
|
produce_request.go
|
4636efcdb8
Proof-of-concept exposing a kafka server API
|
9 anos atrás |
|
produce_request_test.go
|
aa411f16fd
Add decode method to request types
|
9 anos atrás |
|
produce_response.go
|
5509b4a29c
wip
|
11 anos atrás |
|
produce_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
9 anos atrás |
|
real_decoder.go
|
900e4f4595
Centralize and unify getSubset error checking
|
9 anos atrás |
|
real_encoder.go
|
37fcac52fd
Hardcode integer sizes
|
9 anos atrás |
|
request.go
|
66411d8222
Cleanup a bunch more error formats
|
9 anos atrás |
|
request_test.go
|
9b6ac1a0fe
Add mock responses for OffsetManager testing
|
9 anos atrás |
|
response_header.go
|
4636efcdb8
Proof-of-concept exposing a kafka server API
|
9 anos atrás |
|
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
11 anos atrás |
|
sarama.go
|
2ca3f4f970
Update and simplify doc for MaxResponseSize
|
9 anos atrás |
|
server.go
|
1ac0e4f40e
Implement the remaining request/response pairs
|
9 anos atrás |
|
snappy.go
|
0aeb8f0f95
Update snappy repo path and encoding interface
|
9 anos atrás |
|
snappy_test.go
|
0aeb8f0f95
Update snappy repo path and encoding interface
|
9 anos atrás |
|
sync_producer.go
|
6be486f900
Only mention closing the Client on the FromClient constructors
|
9 anos atrás |
|
sync_producer_test.go
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
9 anos atrás |
|
utils.go
|
766d1bfaac
Simplify how we manage seed brokers
|
9 anos atrás |
Evan Huus
