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