 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 |
|
Willem van Bergen
|
91a706483c
Unexport mockbroker.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
87c89f868c
Also prefix KError instances with Err.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
a699b6ff8b
Rename all the things in client tests
|
%!s(int64=9) %!d(string=hai) anos |
 Jack Lindamood
|
e5d6b70726
Cache client partition results to save the repeated sort() calls
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
9073ffbee9
Fix the rebase I screwed up
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
d33e005ce0
Implement Client.WritablePartitions
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
b15933a415
add test
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
430eaee5b4
Actually check the return from Close in our tests
|
%!s(int64=10) %!d(string=hai) anos |
|
Willem van Bergen
|
b04ddbfbea
Rename extraBroker to seedBroker.
|
%!s(int64=10) %!d(string=hai) anos |
|
Evan Huus
|
53701a953d
Make mockbroker's ID an int32 to avoid a boatload of casts
|
%!s(int64=10) %!d(string=hai) anos |
|
Willem van Bergen
|
2bae192c12
Use time.Duration values consistently in *Config types.
|
%!s(int64=10) %!d(string=hai) anos |
|
Willem van Bergen
|
6910a5531c
Add NewClientConfig
|
%!s(int64=10) %!d(string=hai) anos |
 Burke Libbey
|
12297f18bd
Fixed tests
|
%!s(int64=11) %!d(string=hai) anos |
