 Evan Huus
|
6be486f900
Only mention closing the Client on the FromClient constructors
|
%!s(int64=9) %!d(string=hai) anos |
 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
|
a468f3ae10
Make Partition and Offset normal struct fields instead of functions.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
51060e6515
Rename Producer to AsyncProducer
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
f9c4fd65c2
Make Client an interface.
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
4189e55a44
Return{Errors,Successes} -> Return.{Errors,Successes}
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
5411ec3676
Rename Ack* configuration names to Return*, make ReturnErrors default to false for the Consumer, update good and examples
|
%!s(int64=9) %!d(string=hai) anos |
|
Willem van Bergen
|
56542078b1
Configuration tweaks.
|
%!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 |
|
Willem van Bergen
|
fc30281c47
Move the Producer interface to Sarama itself, and make the current Producer struct private.
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
3d6ab1332c
Don't export newSyncProducerFromProducer
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
6e7ef3c572
Permit constructing producers/consumers without clients
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
616ac5daa4
Unify configuration structures into config.go
|
%!s(int64=9) %!d(string=hai) anos |
|
Evan Huus
|
17dc2eeb59
Rename SimpleProducer to SyncProducer
|
%!s(int64=9) %!d(string=hai) anos |
