 Diego Alvarez
|
aff81dac91
make linter happy
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
5d05ad69f7
KIP-42 Add producer and consumer interceptors
|
%!s(int64=4) %!d(string=hai) anos |
 Vlad Gorodetsky
|
6159078aac
Merge pull request #1644 from zendesk/ktsanaktsidis/fix_session_id_thrashing
|
%!s(int64=4) %!d(string=hai) anos |
 KJ Tsanaktsidis
|
b9b3d095f5
Fix brokers continually allocating new Session IDs
|
%!s(int64=4) %!d(string=hai) anos |
 zoushengfu
|
26bbb0417c
bugfix: remove broker which is not exist in metadata
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
88b0e98974
removes unused fields/methods
|
%!s(int64=4) %!d(string=hai) anos |
 Dominic Evans
|
b5630e543b
bug: handle and log throttled FetchResponses
|
%!s(int64=5) %!d(string=hai) anos |
 FrancoisPoinsot
|
0432240e61
test consumer
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
57215a08ac
midway on consumer test
|
%!s(int64=5) %!d(string=hai) anos |
 Varun
|
6a7bac87a0
Merge pull request #1160 from thomaslee/tom_backoff_func
|
%!s(int64=5) %!d(string=hai) anos |
 Sergey Zimin
|
e1eda41894
Tests for timestamps added
|
%!s(int64=5) %!d(string=hai) anos |
 Tom Lee
|
d6f3bc3c43
Add Config.Consumer.Retry.BackoffFunc
|
%!s(int64=6) %!d(string=hai) anos |
 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=7) %!d(string=hai) anos |
|
Vlad Hanciuta
|
953231c528
Add support for Kafka 0.11 in consumer
|
%!s(int64=7) %!d(string=hai) anos |
 Vagrant User
|
9112d76399
Use a ticker instead of a timer to detect timeouts
|
%!s(int64=7) %!d(string=hai) anos |
|
Vagrant User
|
87e4033a66
Optionally use a ticker instead of a timer to detect timeouts
|
%!s(int64=7) %!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=9) %!d(string=hai) anos |
|
Maxim Vladimirsky
|
99f4fd70a5
Introduce mockSequence and further simplify tests
|
%!s(int64=9) %!d(string=hai) anos |
 Evan Huus
|
73244fb45a
Add an example of using the consumer
|
%!s(int64=9) %!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 |
