 Evan Huus
|
74cd0ea353
Handle new errors from kafka 0.8.2
|
11 years ago |
 Willem van Bergen
|
566627d2ad
Make PacketEncodingError and PacketDecodingError more similar to each other.
|
11 years ago |
|
Willem van Bergen
|
87c89f868c
Also prefix KError instances with Err.
|
11 years ago |
|
Willem van Bergen
|
2018fd405e
Prefix error variables with Err
|
11 years ago |
 Willem van Bergen
|
b90ee9d59f
Merge pull request #287 from cep21/master
|
11 years ago |
 Jack Lindamood
|
e5d6b70726
Cache client partition results to save the repeated sort() calls
|
11 years ago |
|
Willem van Bergen
|
802cae39ff
Nicer fetch metadata logging
|
11 years ago |
|
Evan Huus
|
2778be4164
Group related client functions together
|
11 years ago |
|
Evan Huus
|
71e343a459
Scrap the connection test in the client metadata update
|
11 years ago |
|
Evan Huus
|
a7e936b2cd
Log more things
|
11 years ago |
|
Evan Huus
|
21fb992498
If we can't connect, the leader is not available
|
11 years ago |
|
Evan Huus
|
fe696f85ab
Process partition metadata in event of topic-level error
|
11 years ago |
|
Evan Huus
|
722e2eeb76
If the error message is LeaderNotAvailable, don't even look for a leader
|
11 years ago |
|
Evan Huus
|
652d53452a
Log when we run out of retries
|
11 years ago |
|
Willem van Bergen
|
9170d319e4
Handle ReplicaNotAvailable like LeaderNotAvailable when initializing a client
|
11 years ago |
|
Evan Huus
|
1e3e79af80
client: recognize full-topic leader election
|
11 years ago |
|
Evan Huus
|
6f7ffcf78d
Don't fully trust kafka metadata errors
|
11 years ago |
|
Evan Huus
|
7be3f28c7f
Clean up client's refreshMetadata function
|
11 years ago |
|
Evan Huus
|
75c8106b0b
Preparatory steps for the new consumer
|
11 years ago |
|
Evan Huus
|
bf0230952a
tweaks to address code review comments
|
11 years ago |
|
Evan Huus
|
d33e005ce0
Implement Client.WritablePartitions
|
11 years ago |
|
Evan Huus
|
1b465e78c2
Rework how the client handles metadata errors
|
11 years ago |
|
Evan Huus
|
73900d648d
Process all topic/partitions even if one has an error
|
11 years ago |
|
Evan Huus
|
4872214cf2
DRY up two functions
|
11 years ago |
|
Evan Huus
|
bb546b5ff2
Add Replicas() and ReplicasInSync() to client
|
11 years ago |
|
Willem van Bergen
|
f687caad50
Explicitly ignore error return values for some Open and Close calls
|
11 years ago |
|
Evan Huus
|
e594cf0ae1
client: close backgroundMetadataUpdater faster
|
11 years ago |
|
Evan Huus
|
237cfb5380
Check more errors
|
11 years ago |
|
Willem van Bergen
|
b04ddbfbea
Rename extraBroker to seedBroker.
|
11 years ago |
|
Evan Huus
|
c4e1e3344b
If we think the broker is dead, check we can connect
|
11 years ago |
