 Evan Huus
|
7be3f28c7f
Clean up client's refreshMetadata function
|
10 years ago |
|
Evan Huus
|
75c8106b0b
Preparatory steps for the new consumer
|
10 years ago |
|
Evan Huus
|
bf0230952a
tweaks to address code review comments
|
10 years ago |
|
Evan Huus
|
d33e005ce0
Implement Client.WritablePartitions
|
10 years ago |
|
Evan Huus
|
1b465e78c2
Rework how the client handles metadata errors
|
10 years ago |
|
Evan Huus
|
73900d648d
Process all topic/partitions even if one has an error
|
10 years ago |
|
Evan Huus
|
4872214cf2
DRY up two functions
|
10 years ago |
|
Evan Huus
|
bb546b5ff2
Add Replicas() and ReplicasInSync() to client
|
10 years ago |
 Willem van Bergen
|
f687caad50
Explicitly ignore error return values for some Open and Close calls
|
10 years ago |
|
Evan Huus
|
e594cf0ae1
client: close backgroundMetadataUpdater faster
|
10 years ago |
|
Evan Huus
|
237cfb5380
Check more errors
|
10 years ago |
|
Willem van Bergen
|
b04ddbfbea
Rename extraBroker to seedBroker.
|
10 years ago |
|
Evan Huus
|
c4e1e3344b
If we think the broker is dead, check we can connect
|
10 years ago |
|
Evan Huus
|
9c68585f1b
Make deadBrokerAddrs a map to begin with
|
10 years ago |
|
Evan Huus
|
f5d5815754
Merge pull request #144 from Shopify/robust-client-creation
|
10 years ago |
|
Evan Huus
|
b7417e61b0
Add option to refresh metadata on a timer
|
10 years ago |
|
Evan Huus
|
320cc5713b
Don't fail to create the client on LeaderNotAvailable
|
10 years ago |
|
Evan Huus
|
65629827b8
Return better error when server returns no offsets
|
10 years ago |
|
Willem van Bergen
|
c5df84256b
Code review fix
|
10 years ago |
 Rob Rodgers
|
15782aa08d
Address Evan's comments on the previous version. Add checks for Closed() to a few other locations including consumer.go.
|
11 years ago |
|
Rob Rodgers
|
26beb2e678
Add a check to make debugging easier when the client has been closed previously (e.g., an misplaced defer() closed it).
|
11 years ago |
|
Evan Huus
|
737f836006
remove stale comment
|
10 years ago |
|
Evan Huus
|
5cbd22983e
doc tweaks suggested by golint
|
10 years ago |
 Nick Evans
|
6352c9917d
add GetCurrentOffset to client
|
10 years ago |
|
Evan Huus
|
bca4f598d4
Refresh metadata if all partitions are in election
|
10 years ago |
|
Evan Huus
|
113fd78e0a
Add BrokerConfig
|
10 years ago |
|
Willem van Bergen
|
423e478a06
Small fixes
|
10 years ago |
|
Willem van Bergen
|
6910a5531c
Add NewClientConfig
|
10 years ago |
|
Willem van Bergen
|
28b289a868
Do the same for ClientConfig and ProducerConfig
|
10 years ago |
|
Evan Huus
|
be6f649828
Drop pretense of support for Go 1.0
|
10 years ago |
