| .. |
|
consumer.go
|
29c4ebd656
Return an error if the topic/partition is already consumed.
|
11 years ago |
|
consumer_test.go
|
43dbec2ed7
Add mocks.Consumer implementation.
|
11 years ago |
|
mocks.go
|
c85d3d0d49
Fix data race in consumer mock
|
11 years ago |
|
producer.go
|
e4ee98f586
Add package level godoc, fix some typos.
|
11 years ago |
|
producer_test.go
|
25161444de
Enable errcheck on subpackages, and address error handling that was missed before.
|
11 years ago |
|
sync_producer.go
|
e4ee98f586
Add package level godoc, fix some typos.
|
11 years ago |
|
sync_producer_test.go
|
25161444de
Enable errcheck on subpackages, and address error handling that was missed before.
|
11 years ago |
Willem van Bergen
29c4ebd656
Return an error if the topic/partition is already consumed.