| .. |
|
client.go
|
9491dd3ff9
A bit more work for graceful handling of leader election
|
12 gadi atpakaļ |
|
consumer.go
|
254d46da30
Fix consumer receiving no complete messages.
|
12 gadi atpakaļ |
|
errors.go
|
1195e7f8d1
More cleanup, reorg, API tweaks
|
12 gadi atpakaļ |
|
kafka.go
|
9047579808
Split into two packages, one low-level, one high
|
12 gadi atpakaļ |
|
partitioner.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
12 gadi atpakaļ |
|
producer.go
|
889efd2ade
Merge metadata_cache into client.
|
12 gadi atpakaļ |
|
utils.go
|
67829127e3
Don't put message in its own file, it's not big enough to bother
|
12 gadi atpakaļ |
Evan Huus
9491dd3ff9
A bit more work for graceful handling of leader election