 zoushengfu
|
26bbb0417c
bugfix: remove broker which is not exist in metadata
|
4 years ago |
 Blake Caldwell
|
38f81f8298
Updated "retrying" log message when BackoffFunc implemented
|
4 years ago |
 Vlad Gorodetsky
|
07ff436a6d
Fix linter errors
|
4 years ago |
 Dominic Evans
|
5160d7db71
fix: retry topic request on ControllerNotAvailable
|
4 years ago |
 Vlad Gorodetsky
|
afedecade3
Merge pull request #1531 from roblaszczak/master
|
5 years ago |
 Sebastien Launay
|
57d3a2122f
Fix client.tryRefreshMetadata Println
|
5 years ago |
 Robert Laszczak
|
93f4001ec3
fixed race conditions and nil panic on calling registerBroker after close
|
5 years ago |
|
Robert Laszczak
|
a5a3dd2f28
fixed panic on calling updateMetadata on closed client
|
5 years ago |
 mschlos2
|
5e86ab83e7
Actually a topic auth error not group, misread
|
5 years ago |
|
mschlos2
|
fbe15c34cf
Handle a few missed protocol errors and add the new one
|
5 years ago |
|
Vlad Gorodetsky
|
a5ecebcaa3
Merge pull request #1359 from slaunay/enhancement/metadata-refresh-fail-fast
|
5 years ago |
|
Sebastien Launay
|
fe1b1849d0
Support timeout when fetching metadata
|
6 years ago |
|
Dominic Evans
|
ee8eed61c0
feat: support SaslHandshakeRequest v1
|
5 years ago |
|
Vlad Gorodetsky
|
8457f0b57a
Merge pull request #1344 from RazOmessi/master
|
5 years ago |
 Varun
|
3328055d57
another pull request to please lint gods
|
5 years ago |
 razomessi
|
f5564d5773
fix auto create topic on metadata request when request version greater than 3
|
5 years ago |
|
Vlad Gorodetsky
|
a4a1b88c6d
Merge pull request #1318 from drsoares/1311_offline_replicas
|
5 years ago |
 drsoares
|
36113c9237
Merge branch 'master' of github.com:Shopify/sarama into 1311_offline_replicas
|
5 years ago |
 Tormod Erevik Lea
|
c8f961f633
Address a few staticcheck suggestions
|
5 years ago |
 huming
|
f21adde5c6
Make code style consistent in kafka client after refresh metadata
|
6 years ago |
|
drsoares
|
e3ecf7b088
added offline replicas operation to client for kafka version >= 1.x
|
5 years ago |
 Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
5 years ago |
|
Varun
|
6a7bac87a0
Merge pull request #1160 from thomaslee/tom_backoff_func
|
5 years ago |
|
Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
5 years ago |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
6 years ago |
 Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
6 years ago |
 Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
6 years ago |
 Dieter Plaetinck
|
c10e7361b4
allocate properly sized slice up front
|
6 years ago |
 Tom Lee
|
a047cd70e0
Add Config.Metadata.Retry.BackoffFunc
|
6 years ago |
 Evan Huus
|
5cd4d8675b
Merge pull request #1125 from andyxning/fix_topic_metadata_on-demand_fetch
|
6 years ago |
