 Varun
|
25aedae6c3
fixed declaration dependencies and other lint issues (#1743)
|
%!s(int64=4) %!d(string=hai) anos |
 Diego Alvarez
|
4bc9b8f84a
Merge pull request #1738 from varun06/varun-fix-package-name-as-identifier
|
%!s(int64=4) %!d(string=hai) anos |
|
Varun Kumar
|
3f8f953835
run gofmt on async producer test file
|
%!s(int64=4) %!d(string=hai) anos |
|
Varun Kumar
|
8eb2785f4f
removed ide related files and review comments fixes
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
a29994860e
export interceptor methods
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
76f08b8548
use the third person singular present tense
|
%!s(int64=4) %!d(string=hai) anos |
|
Diego Alvarez
|
5d05ad69f7
KIP-42 Add producer and consumer interceptors
|
%!s(int64=4) %!d(string=hai) anos |
|
Varun Kumar
|
f51863e5dd
fixed some variable names
|
%!s(int64=4) %!d(string=hai) anos |
 KJ Tsanaktsidis
|
9df3038ad4
Fix "broker received out of order sequence" when brokers die
|
%!s(int64=4) %!d(string=hai) anos |
 Leonid Koftun
|
2d2326efcf
feat: Add alter and list partition reassignments
|
%!s(int64=4) %!d(string=hai) anos |
 Lars Lehtonen
|
32082edf2b
tests: remove unused testLogger{}
|
%!s(int64=4) %!d(string=hai) anos |
 Vlad Gorodetsky
|
07ff436a6d
Fix linter errors
|
%!s(int64=4) %!d(string=hai) anos |
 Dominic Evans
|
9f8650a8fa
fix brokerProducer goroutine leak (#1442)
|
%!s(int64=5) %!d(string=hai) anos |
 Varun
|
3328055d57
another pull request to please lint gods
|
%!s(int64=5) %!d(string=hai) anos |
 drsoares
|
e3ecf7b088
added offline replicas operation to client for kafka version >= 1.x
|
%!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
|
45ea73e0fb
Merge pull request #1189 from segmentio/maintain-producer-metadata-when-retries-disabled
|
%!s(int64=5) %!d(string=hai) anos |
 Edoardo Comar
|
587c5f694a
Revert to individual msg retries for non-idempotent
|
%!s(int64=6) %!d(string=hai) anos |
 Steve van Loben Sels
|
d86d8e1f78
Abandon broker connection for any error when retries are disabled
|
%!s(int64=6) %!d(string=hai) anos |
|
Steve van Loben Sels
|
459e548c02
simplified code for abandoned connection check, attempt to fix racy sync producer test
|
%!s(int64=6) %!d(string=hai) anos |
|
Steve van Loben Sels
|
9f69c41903
Maintain metadata in the producer even when retries are disabled.
|
%!s(int64=6) %!d(string=hai) anos |
|
Edoardo Comar
|
eb38bbc24f
single metadata refresh for all retries
|
%!s(int64=6) %!d(string=hai) anos |
|
Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
%!s(int64=6) %!d(string=hai) anos |
 Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
%!s(int64=6) %!d(string=hai) anos |
 Tom Lee
|
7d903c1bb8
Add Config.Producer.Retry.BackoffFunc
|
%!s(int64=6) %!d(string=hai) anos |
 Maxim Vladimirskiy
|
1596275bc3
Add timeout to async_producer_test
|
%!s(int64=6) %!d(string=hai) anos |
 Friedrich Große
|
893be7d533
Permit setting version on mock produce response
|
%!s(int64=7) %!d(string=hai) anos |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
%!s(int64=7) %!d(string=hai) anos |
 Evan Huus
|
17b655d247
Producer: block in `Close` without `Return.Errors`
|
%!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 |
