 drsoares
|
e3ecf7b088
added offline replicas operation to client for kafka version >= 1.x
|
преди 5 години |
 Steve van Loben Sels
|
459e548c02
simplified code for abandoned connection check, attempt to fix racy sync producer test
|
преди 5 години |
|
Steve van Loben Sels
|
9f69c41903
Maintain metadata in the producer even when retries are disabled.
|
преди 5 години |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
преди 7 години |
 Evan Huus
|
f0062da5ae
Sync Producer: Don't change config in constructor
|
преди 7 години |
|
Evan Huus
|
0ba346b5da
SyncProducer batch support
|
преди 8 години |
 Maxim Vladimirsky
|
201ab73cb4
Make mock brokers and protocol packets available for outsider
|
преди 8 години |
 Willem van Bergen
|
7f2cdf6cd2
Do not use partition cache for unknown topics.
|
преди 9 години |
|
Willem van Bergen
|
a141cbef2e
Return partition and offset when calling SendMessage.
|
преди 9 години |
|
Willem van Bergen
|
7661952f75
Fix producer test names.
|
преди 9 години |
