| .. |
|
client.go
|
478ae155d5
Don't disconnect tmp broker when creating client
|
12 jaren geleden |
|
consumer.go
|
94bf93c00d
Don't let an error getting leader lead to a nil-pointer
|
12 jaren geleden |
|
errors.go
|
de961cf388
Return a sane error if the partitioner gives a bad partition.
|
12 jaren geleden |
|
partitioner.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
12 jaren geleden |
|
producer.go
|
453e7459cc
Update kafka for new apis
|
12 jaren geleden |
|
utils.go
|
ce2d366f00
Add ByteEncoder util function like StringEncoder
|
12 jaren geleden |
Evan Huus
478ae155d5
Don't disconnect tmp broker when creating client