 Adam Dratwinski
|
d3f8616135
Unblock consumer when receiving invalid FetchResponse
|
%!s(int64=6) %!d(string=hai) anos |
 Sami Hiltunen
|
d9ef2bef2e
advance partition consumer offset after compacted messages
|
%!s(int64=6) %!d(string=hai) anos |
 Vlad Hanciuta
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
%!s(int64=6) %!d(string=hai) anos |
|
Vlad Hanciuta
|
953231c528
Add support for Kafka 0.11 in consumer
|
%!s(int64=6) %!d(string=hai) anos |
 Vagrant User
|
9112d76399
Use a ticker instead of a timer to detect timeouts
|
%!s(int64=6) %!d(string=hai) anos |
|
Vagrant User
|
87e4033a66
Optionally use a ticker instead of a timer to detect timeouts
|
%!s(int64=6) %!d(string=hai) anos |
|
Vagrant User
|
7bbb175476
Add an optional fast checker to (*partitionConsumer).responseFeeder
|
%!s(int64=7) %!d(string=hai) anos |
 Maxim Vladimirsky
|
5d23f48cfe
Makes newMockMetadataResponse exported (fixes #609)
|
%!s(int64=8) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
201ab73cb4
Make mock brokers and protocol packets available for outsider
|
%!s(int64=8) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
99f4fd70a5
Introduce mockSequence and further simplify tests
|
%!s(int64=8) %!d(string=hai) anos |
 Evan Huus
|
73244fb45a
Add an example of using the consumer
|
%!s(int64=8) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
b26b6114e5
Address code inspection comments
|
%!s(int64=9) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
b3fa33fa0c
Further mock broker improvements
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
292f3b0aa1
consumer: don't block on undrained partitions
|
%!s(int64=9) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
da6bc48ffa
Enhance mock broker
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
aff914983c
Add a missing offset check to a test
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
3bd5a52867
Fix/simplify/enable tests
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
5f78d90083
Add high water mark offset support to the consumer.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
c8b3e2e53f
consumer: shut down on OffsetOutOfRange
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
83721053d3
Fix TestConsumerBounceWithReferenceOpen
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
d629146c3e
Consumer: check offset before returning ConsumePartition.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
3b6fa677e9
Hopeful quick fix for flaky CI
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
d988e6dd38
consumer: bugfix for broker workers getting stuck
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
aef773ae4e
Close the consumer master in tests
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
4189e55a44
Return{Errors,Successes} -> Return.{Errors,Successes}
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
251a2dbf7e
Update consumer example comments.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
5411ec3676
Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
01eada75a8
Simplify dispatcher loop
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
0d6a34032f
Make Consumer and PartitionConsumer interfaces.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
ea09ec0652
Add a test for bug #325
|
%!s(int64=9) %!d(string=hai) anos |
