| .. |
|
client.go
|
6d5ee29719
simplify switch
|
12 年之前 |
|
consumer.go
|
94bf93c00d
Don't let an error getting leader lead to a nil-pointer
|
12 年之前 |
|
errors.go
|
de961cf388
Return a sane error if the partitioner gives a bad partition.
|
12 年之前 |
|
partitioner.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
12 年之前 |
|
producer.go
|
453e7459cc
Update kafka for new apis
|
12 年之前 |
|
utils.go
|
ce2d366f00
Add ByteEncoder util function like StringEncoder
|
12 年之前 |