 Vlad Gorodetsky
|
a5ecebcaa3
Merge pull request #1359 from slaunay/enhancement/metadata-refresh-fail-fast
|
%!s(int64=5) %!d(string=hai) anos |
 Sebastien Launay
|
fe1b1849d0
Support timeout when fetching metadata
|
%!s(int64=6) %!d(string=hai) anos |
 Dominic Evans
|
ee8eed61c0
feat: support SaslHandshakeRequest v1
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
8457f0b57a
Merge pull request #1344 from RazOmessi/master
|
%!s(int64=5) %!d(string=hai) anos |
 Varun
|
3328055d57
another pull request to please lint gods
|
%!s(int64=5) %!d(string=hai) anos |
 razomessi
|
f5564d5773
fix auto create topic on metadata request when request version greater than 3
|
%!s(int64=5) %!d(string=hai) anos |
|
Vlad Gorodetsky
|
a4a1b88c6d
Merge pull request #1318 from drsoares/1311_offline_replicas
|
%!s(int64=5) %!d(string=hai) anos |
 drsoares
|
36113c9237
Merge branch 'master' of github.com:Shopify/sarama into 1311_offline_replicas
|
%!s(int64=5) %!d(string=hai) anos |
 Tormod Erevik Lea
|
c8f961f633
Address a few staticcheck suggestions
|
%!s(int64=5) %!d(string=hai) anos |
 huming
|
f21adde5c6
Make code style consistent in kafka client after refresh metadata
|
%!s(int64=6) %!d(string=hai) anos |
|
drsoares
|
e3ecf7b088
added offline replicas operation to client for kafka version >= 1.x
|
%!s(int64=5) %!d(string=hai) anos |
 Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
%!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
|
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 |
 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 |
 Dieter Plaetinck
|
c10e7361b4
allocate properly sized slice up front
|
%!s(int64=6) %!d(string=hai) anos |
 Tom Lee
|
a047cd70e0
Add Config.Metadata.Retry.BackoffFunc
|
%!s(int64=6) %!d(string=hai) anos |
 Evan Huus
|
5cd4d8675b
Merge pull request #1125 from andyxning/fix_topic_metadata_on-demand_fetch
|
%!s(int64=6) %!d(string=hai) anos |
 Andy Xie
|
ce245e83e7
fix producer topic metadata on-demand fetch when topic error happens
|
%!s(int64=6) %!d(string=hai) anos |
|
Evan Huus
|
b836493734
Improve experience trying to get Controller on old versions
|
%!s(int64=6) %!d(string=hai) anos |
 Justfly
|
8a87ca8bca
Merge branch 'master' into master
|
%!s(int64=6) %!d(string=hai) anos |
 justfly
|
e06b9a2882
add Controller() method to Client interface
|
%!s(int64=6) %!d(string=hai) anos |
 Conor Mongey
|
0e0ee63e0d
Clear all metadata when we have the latest info
|
%!s(int64=6) %!d(string=hai) anos |
 Robin
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
%!s(int64=7) %!d(string=hai) anos |
|
Evan Huus
|
34068369ff
Merge pull request #975 from Shopify/return-partial-replicas
|
%!s(int64=7) %!d(string=hai) anos |
 Marko Kevac
|
0e776fb397
add format of an GetOffset argument to documentation
|
%!s(int64=7) %!d(string=hai) anos |
|
Evan Huus
|
84d87a3a41
client: return partial replicas
|
%!s(int64=7) %!d(string=hai) anos |
|
Evan Huus
|
eda03deb5f
Restrict client metadata update more
|
%!s(int64=7) %!d(string=hai) anos |
