 Willem van Bergen
|
a141cbef2e
Return partition and offset when calling SendMessage.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
97c8f951f2
SyncProducer’ SendMessage accepts a sarama.ProducerMessage in line with the AsyncProducer
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
25161444de
Enable errcheck on subpackages, and address error handling that was missed before.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
015a1feac8
Make SyncProducer an interface, and make the original SyncProducer internal. Add a mock for SyncProducer.
|
%!s(int64=9) %!d(string=hai) anos |
