 Evan Huus
|
bed560f780
Add additional error handling based on spec
|
9 lat temu |
|
Evan Huus
|
4678250f1a
Recommend not sharing clients by default
|
10 lat temu |
|
Evan Huus
|
12d29331cf
A few minor suggestions from golint
|
10 lat temu |
|
Evan Huus
|
6facece8ef
Wrap godoc to 80 chars, round 2
|
10 lat temu |
|
Evan Huus
|
93c1f7437d
Wrap all godoc at 80 characters
|
10 lat temu |
 Willem van Bergen
|
e493c2606a
Update godoc for Client.Coordinator and Client.RefreshCoordinator
|
10 lat temu |
|
Willem van Bergen
|
1874f69e22
Shuffle seed brokers so we don't always connect to the first one provided
|
10 lat temu |
|
Willem van Bergen
|
f33811b058
Refactor metadata retro logic and imrove logging.
|
10 lat temu |
|
Evan Huus
|
dd6ba39a5c
client: stop the background thread before closing
|
10 lat temu |
|
Willem van Bergen
|
987c0b95f0
Consistently return ErrClosedClient when calling an exported function on a closed client
|
10 lat temu |
|
Willem van Bergen
|
42e484d7fc
Use a none map for the toRetry topics instead of bool
|
10 lat temu |
|
Willem van Bergen
|
95649f54ca
Add Client.Coordinator(topic) and Client.RefreshCoordinator(topic) to retrieve the coordinating broker for a consumer group.
|
10 lat temu |
|
Evan Huus
|
f922f12eb9
Add retry logic to GetOffset() just like Leader()
|
10 lat temu |
|
Evan Huus
|
766d1bfaac
Simplify how we manage seed brokers
|
10 lat temu |
|
Evan Huus
|
45741c42d0
client: given both retries and errors, prefer retries
|
10 lat temu |
|
Willem van Bergen
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
10 lat temu |
|
Evan Huus
|
f0de0cead8
Cleanup disconnectBroker a bit
|
10 lat temu |
|
Evan Huus
|
48b3c22b7d
Cleanup some client internals
|
10 lat temu |
 Willem van Bergen
|
6877c6e9a2
Merge pull request #348 from Shopify/drop_offsettime
|
10 lat temu |
|
Willem van Bergen
|
47bfe4df50
Update godoc for OffsetOldest and OffsetNewest, and move these to client.go.
|
10 lat temu |
|
Willem van Bergen
|
a9d8315553
Remove OffsetTime in lieu of int64.
|
10 lat temu |
|
Willem van Bergen
|
a8957a931d
Drop ReplicasInSync from Client interface
|
10 lat temu |
|
Willem van Bergen
|
97b7df3b98
Consilidate refresh metadata methods into one
|
10 lat temu |
|
Willem van Bergen
|
f9c4fd65c2
Make Client an interface.
|
10 lat temu |
|
Evan Huus
|
533cce206d
Lazily connect to brokers in the client
|
11 lat temu |
|
Evan Huus
|
9ffa8c742f
Retry UnknownTopicOrPartition on fetching metadata
|
10 lat temu |
|
Evan Huus
|
0e95e22dd4
Various doc and naming tweaks from code review.
|
10 lat temu |
|
Evan Huus
|
0abdf8c4f0
Move the clientID into the config object
|
11 lat temu |
|
Evan Huus
|
616ac5daa4
Unify configuration structures into config.go
|
11 lat temu |
|
Evan Huus
|
74cd0ea353
Handle new errors from kafka 0.8.2
|
11 lat temu |
