 Justin Chen
|
654bd01691
Add method to deregister all connected brokers and provide new seedbroker to fetch metadata
|
%!s(int64=4) %!d(string=hai) anos |
 Pierre Grimaud
|
31886822ab
Fix typos
|
%!s(int64=4) %!d(string=hai) anos |
 zoushengfu
|
26bbb0417c
bugfix: remove broker which is not exist in metadata
|
%!s(int64=4) %!d(string=hai) anos |
 Lars Lehtonen
|
e5ac353cdd
fix: remove use of t.testing.FailNow() inside goroutine
|
%!s(int64=4) %!d(string=hai) anos |
 Sebastien Launay
|
fe1b1849d0
Support timeout when fetching 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 |
 Tom Lee
|
a047cd70e0
Add Config.Metadata.Retry.BackoffFunc
|
%!s(int64=6) %!d(string=hai) anos |
 Evan Huus
|
5d35641fb5
Fix test
|
%!s(int64=6) %!d(string=hai) anos |
 justfly
|
e06b9a2882
add Controller() method to Client interface
|
%!s(int64=6) %!d(string=hai) anos |
 git-hulk
|
240ddc7211
FIX: It shouldn't sort the replicas and isr while the order is
|
%!s(int64=7) %!d(string=hai) anos |
 Kyle Hargraves
|
dbc0382c17
Rename client.Isr to client.InSyncReplicas
|
%!s(int64=7) %!d(string=hai) anos |
|
Kyle Hargraves
|
f79a4d6153
Add Isr to Client interface
|
%!s(int64=7) %!d(string=hai) anos |
 Maxim Vladimirsky
|
201ab73cb4
Make mock brokers and protocol packets available for outsider
|
%!s(int64=9) %!d(string=hai) anos |
 Willem van Bergen
|
1874f69e22
Shuffle seed brokers so we don't always connect to the first one provided
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
fbe4417e0b
Add some simple producer benchmarks
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
52af5d953e
Disable background metadata updater in a test
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
dd6ba39a5c
client: stop the background thread before closing
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
95649f54ca
Add Client.Coordinator(topic) and Client.RefreshCoordinator(topic) to retrieve the coordinating broker for a consumer group.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
f922f12eb9
Add retry logic to GetOffset() just like Leader()
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
5cfe247359
Add test for resurrecting dead seeds
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
b94609120c
Permit Metadata.Retry.Backoff == 0
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
e41ef46cf6
Add some tests on how the client should handle errors in the metadata response.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
f0de0cead8
Cleanup disconnectBroker a bit
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
a8957a931d
Drop ReplicasInSync from Client interface
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
f9c4fd65c2
Make Client an interface.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
533cce206d
Lazily connect to brokers in the client
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
0e95e22dd4
Various doc and naming tweaks from code review.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
0abdf8c4f0
Move the clientID into the config object
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
616ac5daa4
Unify configuration structures into config.go
|
%!s(int64=9) %!d(string=hai) anos |
