 Evan Huus
|
f0de0cead8
Cleanup disconnectBroker a bit
|
9 years ago |
|
Evan Huus
|
48b3c22b7d
Cleanup some client internals
|
9 years ago |
 Willem van Bergen
|
6877c6e9a2
Merge pull request #348 from Shopify/drop_offsettime
|
9 years ago |
 Willem van Bergen
|
47bfe4df50
Update godoc for OffsetOldest and OffsetNewest, and move these to client.go.
|
9 years ago |
|
Willem van Bergen
|
a9d8315553
Remove OffsetTime in lieu of int64.
|
9 years ago |
|
Willem van Bergen
|
a8957a931d
Drop ReplicasInSync from Client interface
|
9 years ago |
|
Willem van Bergen
|
97b7df3b98
Consilidate refresh metadata methods into one
|
9 years ago |
|
Willem van Bergen
|
f9c4fd65c2
Make Client an interface.
|
9 years ago |
|
Evan Huus
|
533cce206d
Lazily connect to brokers in the client
|
9 years ago |
|
Evan Huus
|
9ffa8c742f
Retry UnknownTopicOrPartition on fetching metadata
|
9 years ago |
|
Evan Huus
|
0e95e22dd4
Various doc and naming tweaks from code review.
|
9 years ago |
|
Evan Huus
|
0abdf8c4f0
Move the clientID into the config object
|
9 years ago |
|
Evan Huus
|
616ac5daa4
Unify configuration structures into config.go
|
9 years ago |
|
Evan Huus
|
74cd0ea353
Handle new errors from kafka 0.8.2
|
9 years ago |
|
Willem van Bergen
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
9 years ago |
|
Willem van Bergen
|
87c89f868c
Also prefix KError instances with Err.
|
9 years ago |
|
Willem van Bergen
|
2018fd405e
Prefix error variables with Err
|
9 years ago |
|
Willem van Bergen
|
b90ee9d59f
Merge pull request #287 from cep21/master
|
9 years ago |
 Jack Lindamood
|
e5d6b70726
Cache client partition results to save the repeated sort() calls
|
9 years ago |
|
Willem van Bergen
|
802cae39ff
Nicer fetch metadata logging
|
9 years ago |
|
Evan Huus
|
2778be4164
Group related client functions together
|
9 years ago |
|
Evan Huus
|
71e343a459
Scrap the connection test in the client metadata update
|
9 years ago |
|
Evan Huus
|
a7e936b2cd
Log more things
|
9 years ago |
|
Evan Huus
|
21fb992498
If we can't connect, the leader is not available
|
9 years ago |
|
Evan Huus
|
fe696f85ab
Process partition metadata in event of topic-level error
|
9 years ago |
|
Evan Huus
|
722e2eeb76
If the error message is LeaderNotAvailable, don't even look for a leader
|
9 years ago |
|
Evan Huus
|
652d53452a
Log when we run out of retries
|
9 years ago |
|
Willem van Bergen
|
9170d319e4
Handle ReplicaNotAvailable like LeaderNotAvailable when initializing a client
|
9 years ago |
|
Evan Huus
|
1e3e79af80
client: recognize full-topic leader election
|
9 years ago |
|
Evan Huus
|
6f7ffcf78d
Don't fully trust kafka metadata errors
|
9 years ago |
