| .. |
|
client.go
|
9491dd3ff9
A bit more work for graceful handling of leader election
|
12 years ago |
|
consumer.go
|
1a4ee4cbad
More error handling in consumer
|
12 years ago |
|
errors.go
|
1195e7f8d1
More cleanup, reorg, API tweaks
|
12 years ago |
|
kafka.go
|
9047579808
Split into two packages, one low-level, one high
|
12 years ago |
|
partitioner.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
12 years ago |
|
producer.go
|
a6b4d16e4f
Fix possible infinite loop
|
12 years ago |
|
utils.go
|
67829127e3
Don't put message in its own file, it's not big enough to bother
|
12 years ago |
Evan Huus
1a4ee4cbad
More error handling in consumer