 francois
|
98b2c4a922
Merge branch 'master' into read-committed
|
6 years ago |
|
FrancoisPoinsot
|
077e5d4f7b
PR fixes:
|
6 years ago |
|
FrancoisPoinsot
|
eb3cb9538e
handle todos
|
6 years ago |
 Vlad Gorodetsky
|
2b2fccd2d2
Merge pull request #1296 from varun06/add-consumer-batchsize-metric
|
6 years ago |
|
Vlad Gorodetsky
|
da30382100
Merge pull request #1156 from imjustfly/master
|
6 years ago |
 Varun
|
af26fcd370
Merge branch 'master' into add-consumer-batchsize-metric
|
6 years ago |
|
FrancoisPoinsot
|
10d673ff22
copied transaction logic from java client
|
6 years ago |
|
FrancoisPoinsot
|
b68420a29b
control record + isTransactional bit parsing
|
6 years ago |
|
FrancoisPoinsot
|
559a3ceebb
not working, handle only single message transaction
|
6 years ago |
|
Varun
|
105ef2520c
removed references to sarama-cluster
|
6 years ago |
|
Varun
|
bdafe52dd1
fixed an error check analysis issue
|
6 years ago |
|
Varun
|
82f2b35fe8
Merge branch 'master' into random-lint-fix
|
6 years ago |
|
Varun
|
36b0b387c7
preallocate message slice and random fixes
|
6 years ago |
 Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
6 years ago |
|
Varun
|
4ecd1e57c5
added a metric to expose consumer batch size
|
6 years ago |
|
Varun
|
6a7bac87a0
Merge pull request #1160 from thomaslee/tom_backoff_func
|
6 years ago |
|
Vlad Gorodetsky
|
a3e71cf226
Merge pull request #1227 from gburanov/fix_consuming_compressed_topic
|
6 years ago |
 Georgy Buranov
|
36aaf2eb0e
Fix consuming compacted topic
|
6 years ago |
 Sergey Zimin
|
e1eda41894
Tests for timestamps added
|
6 years ago |
|
Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
6 years ago |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
6 years ago |
|
Sergey Zimin
|
f0e5fa7ff7
Support LogAppend timestamps
|
6 years ago |
 Tom Lee
|
d6f3bc3c43
Add Config.Consumer.Retry.BackoffFunc
|
6 years ago |
 justfly
|
dcc4684462
optimized compatibility
|
6 years ago |
|
justfly
|
58a9d32ae0
dont't drain PartitionConsumer's messages channel when closing
|
6 years ago |
 Evan Huus
|
807de26ba5
Fix block on control messages
|
6 years ago |
|
Evan Huus
|
e19e955323
Merge pull request #1086 from adwinsky/fix-consumer-block-when-receiving-invalid-fetch-response
|
6 years ago |
 Dimitrij Denissenko
|
a1ad496b31
Make PartitionConsumer.Close idempotent
|
7 years ago |
 Adam Dratwinski
|
d3f8616135
Unblock consumer when receiving invalid FetchResponse
|
7 years ago |
|
Evan Huus
|
eae91468c2
consumer: don't stop the ticker if we time out
|
7 years ago |
