| .. |
|
client.go
|
19409ffdc5
Add a test, fix a bug.
|
13 anni fa |
|
client_test.go
|
19409ffdc5
Add a test, fix a bug.
|
13 anni fa |
|
consumer.go
|
94bf93c00d
Don't let an error getting leader lead to a nil-pointer
|
13 anni fa |
|
errors.go
|
de961cf388
Return a sane error if the partitioner gives a bad partition.
|
13 anni fa |
|
partitioner.go
|
46b3d6e171
Client.Close(), RoundRobinPartitioner, documentation
|
13 anni fa |
|
partitioner_test.go
|
9fc922b7ce
partitioner tests
|
13 anni fa |
|
producer.go
|
453e7459cc
Update kafka for new apis
|
13 anni fa |
|
utils.go
|
ce2d366f00
Add ByteEncoder util function like StringEncoder
|
13 anni fa |
Evan Huus
19409ffdc5
Add a test, fix a bug.