 andrewhao888
|
c50148e0a8
fetch size overflow (#1376)
|
%!s(int64=5) %!d(string=hai) anos |
 Dominic Evans
|
b5630e543b
bug: handle and log throttled FetchResponses
|
%!s(int64=5) %!d(string=hai) anos |
 Vlad Gorodetsky
|
da02f5b7f6
Merge pull request #1337 from tormoder/staticcheck-base-pkg
|
%!s(int64=5) %!d(string=hai) anos |
 Tormod Erevik Lea
|
c8f961f633
Address a few staticcheck suggestions
|
%!s(int64=5) %!d(string=hai) anos |
 francois
|
d2e4a4d587
rm unnecessary logic: abort message on batch level
|
%!s(int64=5) %!d(string=hai) anos |
|
francois
|
98b2c4a922
Merge branch 'master' into read-committed
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
077e5d4f7b
PR fixes:
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
eb3cb9538e
handle todos
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
2b2fccd2d2
Merge pull request #1296 from varun06/add-consumer-batchsize-metric
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
da30382100
Merge pull request #1156 from imjustfly/master
|
%!s(int64=5) %!d(string=hai) anos |
 Varun
|
af26fcd370
Merge branch 'master' into add-consumer-batchsize-metric
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
10d673ff22
copied transaction logic from java client
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
b68420a29b
control record + isTransactional bit parsing
|
%!s(int64=5) %!d(string=hai) anos |
|
FrancoisPoinsot
|
559a3ceebb
not working, handle only single message transaction
|
%!s(int64=5) %!d(string=hai) anos |
|
Varun
|
105ef2520c
removed references to sarama-cluster
|
%!s(int64=5) %!d(string=hai) anos |
|
Varun
|
bdafe52dd1
fixed an error check analysis issue
|
%!s(int64=5) %!d(string=hai) anos |
|
Varun
|
82f2b35fe8
Merge branch 'master' into random-lint-fix
|
%!s(int64=5) %!d(string=hai) anos |
|
Varun
|
36b0b387c7
preallocate message slice and random fixes
|
%!s(int64=5) %!d(string=hai) anos |
 Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
%!s(int64=5) %!d(string=hai) anos |
|
Varun
|
4ecd1e57c5
added a metric to expose consumer batch size
|
%!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 |
|
Vlad Gorodetsky
|
a3e71cf226
Merge pull request #1227 from gburanov/fix_consuming_compressed_topic
|
%!s(int64=5) %!d(string=hai) anos |
 Georgy Buranov
|
36aaf2eb0e
Fix consuming compacted topic
|
%!s(int64=6) %!d(string=hai) anos |
 Sergey Zimin
|
e1eda41894
Tests for timestamps added
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
%!s(int64=5) %!d(string=hai) anos |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
%!s(int64=6) %!d(string=hai) anos |
|
Sergey Zimin
|
f0e5fa7ff7
Support LogAppend timestamps
|
%!s(int64=5) %!d(string=hai) anos |
 Tom Lee
|
d6f3bc3c43
Add Config.Consumer.Retry.BackoffFunc
|
%!s(int64=6) %!d(string=hai) anos |
 justfly
|
dcc4684462
optimized compatibility
|
%!s(int64=6) %!d(string=hai) anos |
|
justfly
|
58a9d32ae0
dont't drain PartitionConsumer's messages channel when closing
|
%!s(int64=6) %!d(string=hai) anos |
