 huming
|
f21adde5c6
Make code style consistent in kafka client after refresh metadata
|
7 years ago |
 Nelz
|
6c354b8b3c
reduce client close bookkeeping
|
6 years ago |
 Varun
|
6a7bac87a0
Merge pull request #1160 from thomaslee/tom_backoff_func
|
7 years ago |
 Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
7 years ago |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
7 years ago |
 Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
7 years ago |
 Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
7 years ago |
 Dieter Plaetinck
|
c10e7361b4
allocate properly sized slice up front
|
7 years ago |
 Tom Lee
|
a047cd70e0
Add Config.Metadata.Retry.BackoffFunc
|
7 years ago |
 Evan Huus
|
5cd4d8675b
Merge pull request #1125 from andyxning/fix_topic_metadata_on-demand_fetch
|
7 years ago |
 Andy Xie
|
ce245e83e7
fix producer topic metadata on-demand fetch when topic error happens
|
7 years ago |
|
Evan Huus
|
b836493734
Improve experience trying to get Controller on old versions
|
7 years ago |
 Justfly
|
8a87ca8bca
Merge branch 'master' into master
|
7 years ago |
 justfly
|
e06b9a2882
add Controller() method to Client interface
|
7 years ago |
 Conor Mongey
|
0e0ee63e0d
Clear all metadata when we have the latest info
|
8 years ago |
 Robin
|
a5a9b835af
refactor ConsumerMetadataRequest/Response to FindCoordinatorRequest/Response
|
8 years ago |
|
Evan Huus
|
34068369ff
Merge pull request #975 from Shopify/return-partial-replicas
|
8 years ago |
 Marko Kevac
|
0e776fb397
add format of an GetOffset argument to documentation
|
8 years ago |
|
Evan Huus
|
84d87a3a41
client: return partial replicas
|
8 years ago |
|
Evan Huus
|
eda03deb5f
Restrict client metadata update more
|
8 years ago |
|
Evan Huus
|
38673c0ce0
Add a config option to store only minimal metadata
|
8 years ago |
 git-hulk
|
240ddc7211
FIX: It shouldn't sort the replicas and isr while the order is
|
8 years ago |
 Kyle Hargraves
|
dbc0382c17
Rename client.Isr to client.InSyncReplicas
|
8 years ago |
|
Kyle Hargraves
|
f79a4d6153
Add Isr to Client interface
|
8 years ago |
 funkygao
|
c57f8cfa66
client will export isr info of a topic/partition
|
10 years ago |
 DiSiqueira
|
fdebee00c4
Following Golint tips for if blocks who ends with a return
|
9 years ago |
|
DiSiqueira
|
7d13d169ae
Fixing two typos
|
9 years ago |
 Benedikt Böhm
|
b9842b64e1
hold read lock while reading brokers
|
9 years ago |
|
Benedikt Böhm
|
3276070875
do not create sparse array
|
9 years ago |
|
Benedikt Böhm
|
56f3f2bc9d
make list of brokers available through sarama.Client
|
9 years ago |
