 Vlad Gorodetsky
|
e6c029ff1a
Revert "Synced error names and descriptions with the kafka's protocol"
|
%!s(int64=5) %!d(string=hai) anos |
 Nick Revin
|
a0f0d8fcdf
synced error codes and descriptions with the kafka's protocol
|
%!s(int64=6) %!d(string=hai) anos |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
%!s(int64=7) %!d(string=hai) anos |
 Willem van Bergen
|
2052bd96dc
Add Topics() and Partitions to Consumer, and mock Consumer.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
abfb8a5a6f
Add tests for channel draining expectations.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
532c0656d3
OnPartition -> ExpectConsumePartition.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
43dbec2ed7
Add mocks.Consumer implementation.
|
%!s(int64=9) %!d(string=hai) anos |
