 Evan Huus
|
eae91468c2
consumer: don't stop the ticker if we time out
|
6 years ago |
 Maxim Vladimirskiy
|
5468405d94
Expose Records union fields
|
6 years ago |
|
Maxim Vladimirskiy
|
973e75ca79
Simplify messageSet and recordBatch parsing
|
6 years ago |
|
Maxim Vladimirskiy
|
d2959fa106
Report ErrIncompleteResponse if nothing is retrieved only
|
6 years ago |
|
Evan Huus
|
5910255fbe
Merge pull request #1028 from faceair/master
|
6 years ago |
 faceair
|
57f03c7bfa
Consumer: reduce ticker allocations
|
6 years ago |
 Thomas Sanchez
|
cd0485eacc
Avoid Ticker leak in case of slow consumer
|
6 years ago |
 Ivan Babrou
|
c8284bbf5c
Minimize diff with master
|
6 years ago |
|
Ivan Babrou
|
d7d2bb7b2b
Support multiple mixed Record types
|
6 years ago |
|
Ivan Babrou
|
068e0b77c8
Support multiple record batches, closes #1022
|
6 years ago |
 Sami Hiltunen
|
d9ef2bef2e
advance partition consumer offset after compacted messages
|
7 years ago |
 Vlad Hanciuta
|
b7f694ebc8
Determine the records type based on the magic number not API version
|
7 years ago |
|
Evan Huus
|
10f33bec2a
consumer: don't check LastStableOffset
|
7 years ago |
|
Vlad Hanciuta
|
ed80c61d79
Make timestamp fields of type time.Time and time.Duration
|
7 years ago |
|
Vlad Hanciuta
|
953231c528
Add support for Kafka 0.11 in consumer
|
7 years ago |
 Vagrant User
|
87e4033a66
Optionally use a ticker instead of a timer to detect timeouts
|
7 years ago |
|
Vagrant User
|
7bbb175476
Add an optional fast checker to (*partitionConsumer).responseFeeder
|
7 years ago |
 Michael Herstine
|
45f017b7f4
Docstring change only to PartitionConsumer.
|
7 years ago |
|
Evan Huus
|
2fd980e23b
Merge pull request #905 from sp1ff/master
|
7 years ago |
|
Michael Herstine
|
b69551c88b
Add support for FetchRequest API V3.
|
7 years ago |
|
Michael Herstine
|
4d1eceb890
Added support for FetchRequest protocol version 3.
|
7 years ago |
 DV
|
ce6585f068
#885: added BlockTimestamp to ConsumerMessage
|
7 years ago |
|
Evan Huus
|
7f63d35b79
Fix an additional possible alignment issue
|
7 years ago |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
7 years ago |
|
Evan Huus
|
8d739a4669
Tweak some docs
|
8 years ago |
 Mathieu Payeur Levallois
|
b0e729b8e9
Fix HighWaterMarks() comment
|
8 years ago |
|
Mathieu Payeur Levallois
|
f66f2deeff
Add Consumer.HighWaterMarks()
|
8 years ago |
|
Evan Huus
|
16da292b17
Consumer: handle compressed relative offsets
|
8 years ago |
 Nimi Wariboko Jr
|
f0f5b0ae1a
Consumer: fix deadlock - if the timer had already expired, don't try to read the channel again.
|
8 years ago |
|
Nimi Wariboko Jr
|
779ef6ae4e
Checking Reset()'s active return value is racy according to Golang docs. Docs advice to call Stop inorder to reuse a timer. Should fix #732.
|
8 years ago |
