 Willem van Bergen
|
5f78d90083
Add high water mark offset support to the consumer.
|
10 years ago |
 Willem van Bergen
|
2052bd96dc
Add Topics() and Partitions to Consumer, and mock Consumer.
|
10 years ago |
|
Willem van Bergen
|
abfb8a5a6f
Add tests for channel draining expectations.
|
10 years ago |
|
Willem van Bergen
|
532c0656d3
OnPartition -> ExpectConsumePartition.
|
10 years ago |
|
Willem van Bergen
|
61ca52d100
Godoc
|
10 years ago |
|
Willem van Bergen
|
29c4ebd656
Return an error if the topic/partition is already consumed.
|
10 years ago |
|
Willem van Bergen
|
c85d3d0d49
Fix data race in consumer mock
|
10 years ago |
|
Willem van Bergen
|
43dbec2ed7
Add mocks.Consumer implementation.
|
10 years ago |
