|
examples
|
9fd83b3752
Fix a few README typos
|
10 lat temu |
|
mocks
|
5f78d90083
Add high water mark offset support to the consumer.
|
10 lat temu |
|
tools
|
01d71fed9e
Fix tool installation instructions in READMEs
|
10 lat temu |
|
vagrant
|
f8432e85f5
Bump toxiproxy version
|
10 lat temu |
|
.gitignore
|
d3bc825c36
Add Vagrantfile, and provisioning scripts that set up a working 5-node cluster.
|
11 lat temu |
|
.travis.yml
|
1cb275416d
Tweak travis config
|
10 lat temu |
|
CHANGELOG.md
|
43a8ef117a
update changelog
|
10 lat temu |
|
CONTRIBUTING.md
|
6aacbb7d86
Some additions
|
11 lat temu |
|
MIT-LICENSE
|
86b4691cdd
Add license information
|
12 lat temu |
|
Makefile
|
d482af099e
Connect to toxiproxy in functional tests
|
10 lat temu |
|
README.md
|
3e02f29af4
Update READMEs
|
10 lat temu |
|
Vagrantfile
|
cf5665ab9a
Increase memory with vagrant virtualbox
|
10 lat temu |
|
async_producer.go
|
26a20bdaff
Clear producer message retry field on success
|
10 lat temu |
|
async_producer_test.go
|
08ccf5e1b5
Add a test for retries during shutdow
|
10 lat temu |
|
broker.go
|
f33811b058
Refactor metadata retro logic and imrove logging.
|
10 lat temu |
|
broker_test.go
|
0abdf8c4f0
Move the clientID into the config object
|
10 lat temu |
|
client.go
|
1874f69e22
Shuffle seed brokers so we don't always connect to the first one provided
|
10 lat temu |
|
client_test.go
|
1874f69e22
Shuffle seed brokers so we don't always connect to the first one provided
|
10 lat temu |
|
config.go
|
449c713de0
Adding equals sign to the invalid config message
|
10 lat temu |
|
config_test.go
|
616ac5daa4
Unify configuration structures into config.go
|
10 lat temu |
|
consumer.go
|
7c4fa7452a
Document consumergroup repo location
|
10 lat temu |
|
consumer_metadata_request.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 lat temu |
|
consumer_metadata_request_test.go
|
9520ed2cbd
Implement consumer metadata request/response pair
|
11 lat temu |
|
consumer_metadata_response.go
|
95649f54ca
Add Client.Coordinator(topic) and Client.RefreshCoordinator(topic) to retrieve the coordinating broker for a consumer group.
|
10 lat temu |
|
consumer_metadata_response_test.go
|
5d12edf304
Add a test
|
10 lat temu |
|
consumer_test.go
|
3bd5a52867
Fix/simplify/enable tests
|
10 lat temu |
|
crc32_field.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
10 lat temu |
|
encoder_decoder.go
|
f35cfe20d9
Make MaxRequestSize signed for consistency with MaxResponseSize
|
10 lat temu |
|
errors.go
|
3aab8e4fdd
tweak some errors
|
10 lat temu |
|
fetch_request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 lat temu |
|
fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 lat temu |
|
fetch_response.go
|
75c8106b0b
Preparatory steps for the new consumer
|
11 lat temu |
|
fetch_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
10 lat temu |
|
functional_client_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
10 lat temu |
|
functional_consumer_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
10 lat temu |
|
functional_producer_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
10 lat temu |
|
functional_test.go
|
f0fc7e9247
Finalize most of the toxiproxy test framework
|
10 lat temu |
|
length_field.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
10 lat temu |
|
message.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
10 lat temu |
|
message_set.go
|
2018fd405e
Prefix error variables with Err
|
10 lat temu |
|
message_test.go
|
9675a91962
Added Gzip test. Simplified a little.
|
12 lat temu |
|
metadata_request.go
|
4969d24fa1
kafka->sarama
|
12 lat temu |
|
metadata_request_test.go
|
4969d24fa1
kafka->sarama
|
12 lat temu |
|
metadata_response.go
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
10 lat temu |
|
metadata_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
10 lat temu |
|
mockbroker_test.go
|
83721053d3
Fix TestConsumerBounceWithReferenceOpen
|
10 lat temu |
|
offset_commit_request.go
|
f3c86b0317
The wiki of the offset API has been updated again
|
10 lat temu |
|
offset_commit_request_test.go
|
e6dbbebb8e
Refactor offset commit request tests so they don't cause warnings
|
10 lat temu |
|
offset_commit_response.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
11 lat temu |
|
offset_commit_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
10 lat temu |
|
offset_fetch_request.go
|
f3c86b0317
The wiki of the offset API has been updated again
|
10 lat temu |
|
offset_fetch_request_test.go
|
4969d24fa1
kafka->sarama
|
12 lat temu |
|
offset_fetch_response.go
|
aa133ab822
Fix offset commit/fetch compatibility with kafka 0.8.1
|
11 lat temu |
|
offset_fetch_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
10 lat temu |
|
offset_request.go
|
a9d8315553
Remove OffsetTime in lieu of int64.
|
10 lat temu |
|
offset_request_test.go
|
4969d24fa1
kafka->sarama
|
12 lat temu |
|
offset_response.go
|
39823e3af9
Check some errors
|
11 lat temu |
|
offset_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
10 lat temu |
|
packet_decoder.go
|
4969d24fa1
kafka->sarama
|
12 lat temu |
|
packet_encoder.go
|
2f5cf8fd16
Fixed remaining test.
|
12 lat temu |
|
partitioner.go
|
1101246f70
Pass the topic to the partitioner constructor
|
10 lat temu |
|
partitioner_test.go
|
faec514115
Add an example for different partitioning per topic.
|
10 lat temu |
|
prep_encoder.go
|
37fcac52fd
Hardcode integer sizes
|
10 lat temu |
|
produce_request.go
|
0d17c78f48
producer: add warning about RequiredAcks>1
|
11 lat temu |
|
produce_request_test.go
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
11 lat temu |
|
produce_response.go
|
5509b4a29c
wip
|
12 lat temu |
|
produce_response_test.go
|
87c89f868c
Also prefix KError instances with Err.
|
10 lat temu |
|
real_decoder.go
|
37fcac52fd
Hardcode integer sizes
|
10 lat temu |
|
real_encoder.go
|
37fcac52fd
Hardcode integer sizes
|
10 lat temu |
|
request.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 lat temu |
|
request_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 lat temu |
|
response_header.go
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
10 lat temu |
|
response_header_test.go
|
893044d278
Fix Golint errors, except for all the missing comments.
|
12 lat temu |
|
sarama.go
|
f35cfe20d9
Make MaxRequestSize signed for consistency with MaxResponseSize
|
10 lat temu |
|
snappy.go
|
cabc1b4ffc
golint: use var block, and simply use a variable declaration to create a byteslice with a length of 0
|
10 lat temu |
|
snappy_test.go
|
b5df04ed3e
Make snappy functions private
|
11 lat temu |
|
sync_producer.go
|
6be486f900
Only mention closing the Client on the FromClient constructors
|
10 lat temu |
|
sync_producer_test.go
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
10 lat temu |
|
utils.go
|
766d1bfaac
Simplify how we manage seed brokers
|
10 lat temu |
Evan Huus
