 Evan Huus
|
a7e936b2cd
Log more things
|
il y a 11 ans |
|
Evan Huus
|
21fb992498
If we can't connect, the leader is not available
|
il y a 11 ans |
|
Evan Huus
|
fe696f85ab
Process partition metadata in event of topic-level error
|
il y a 11 ans |
|
Evan Huus
|
722e2eeb76
If the error message is LeaderNotAvailable, don't even look for a leader
|
il y a 11 ans |
|
Evan Huus
|
652d53452a
Log when we run out of retries
|
il y a 11 ans |
 Willem van Bergen
|
9170d319e4
Handle ReplicaNotAvailable like LeaderNotAvailable when initializing a client
|
il y a 11 ans |
|
Evan Huus
|
1e3e79af80
client: recognize full-topic leader election
|
il y a 11 ans |
|
Evan Huus
|
6f7ffcf78d
Don't fully trust kafka metadata errors
|
il y a 11 ans |
|
Evan Huus
|
7be3f28c7f
Clean up client's refreshMetadata function
|
il y a 11 ans |
|
Evan Huus
|
75c8106b0b
Preparatory steps for the new consumer
|
il y a 11 ans |
|
Evan Huus
|
bf0230952a
tweaks to address code review comments
|
il y a 11 ans |
|
Evan Huus
|
d33e005ce0
Implement Client.WritablePartitions
|
il y a 11 ans |
|
Evan Huus
|
1b465e78c2
Rework how the client handles metadata errors
|
il y a 11 ans |
|
Evan Huus
|
73900d648d
Process all topic/partitions even if one has an error
|
il y a 11 ans |
|
Evan Huus
|
4872214cf2
DRY up two functions
|
il y a 11 ans |
|
Evan Huus
|
bb546b5ff2
Add Replicas() and ReplicasInSync() to client
|
il y a 11 ans |
|
Willem van Bergen
|
f687caad50
Explicitly ignore error return values for some Open and Close calls
|
il y a 11 ans |
|
Evan Huus
|
e594cf0ae1
client: close backgroundMetadataUpdater faster
|
il y a 11 ans |
|
Evan Huus
|
237cfb5380
Check more errors
|
il y a 11 ans |
|
Willem van Bergen
|
b04ddbfbea
Rename extraBroker to seedBroker.
|
il y a 11 ans |
|
Evan Huus
|
c4e1e3344b
If we think the broker is dead, check we can connect
|
il y a 11 ans |
|
Evan Huus
|
9c68585f1b
Make deadBrokerAddrs a map to begin with
|
il y a 11 ans |
|
Evan Huus
|
f5d5815754
Merge pull request #144 from Shopify/robust-client-creation
|
il y a 11 ans |
|
Evan Huus
|
b7417e61b0
Add option to refresh metadata on a timer
|
il y a 11 ans |
|
Evan Huus
|
320cc5713b
Don't fail to create the client on LeaderNotAvailable
|
il y a 11 ans |
|
Evan Huus
|
65629827b8
Return better error when server returns no offsets
|
il y a 11 ans |
|
Willem van Bergen
|
c5df84256b
Code review fix
|
il y a 11 ans |
 Rob Rodgers
|
15782aa08d
Address Evan's comments on the previous version. Add checks for Closed() to a few other locations including consumer.go.
|
il y a 12 ans |
|
Rob Rodgers
|
26beb2e678
Add a check to make debugging easier when the client has been closed previously (e.g., an misplaced defer() closed it).
|
il y a 12 ans |
|
Evan Huus
|
737f836006
remove stale comment
|
il y a 11 ans |
