 Edoardo Comar
|
587c5f694a
Revert to individual msg retries for non-idempotent
|
7 gadi atpakaļ |
|
Edoardo Comar
|
eb38bbc24f
single metadata refresh for all retries
|
7 gadi atpakaļ |
|
Edoardo Comar
|
4e5d477980
Idempotent Producer - batch retry logic
|
7 gadi atpakaļ |
 Mickael Maison
|
8e2b04b363
Added support for Idempotent Producer
|
7 gadi atpakaļ |
 Maxim Vladimirskiy
|
1596275bc3
Add timeout to async_producer_test
|
7 gadi atpakaļ |
 Friedrich Große
|
893be7d533
Permit setting version on mock produce response
|
8 gadi atpakaļ |
 DiSiqueira
|
cecb3d9807
Formating all files with gofmt -s
|
8 gadi atpakaļ |
 Evan Huus
|
17b655d247
Producer: block in `Close` without `Return.Errors`
|
9 gadi atpakaļ |
|
Maxim Vladimirsky
|
201ab73cb4
Make mock brokers and protocol packets available for outsider
|
10 gadi atpakaļ |
|
Evan Huus
|
733c74f30d
Refactor the producer, part 2
|
10 gadi atpakaļ |
|
Evan Huus
|
7e88a995fe
Add test for encoding failures
|
10 gadi atpakaļ |
|
Evan Huus
|
737294ce64
Fix the flakiest producer test
|
10 gadi atpakaļ |
|
Maxim Vladimirsky
|
da6bc48ffa
Enhance mock broker
|
10 gadi atpakaļ |
|
Evan Huus
|
b21ab845b5
Add a custom-partitioner test
|
10 gadi atpakaļ |
|
Evan Huus
|
08ccf5e1b5
Add a test for retries during shutdow
|
10 gadi atpakaļ |
|
Evan Huus
|
a381b3667d
producer: bugfix for aggregators getting stuck
|
10 gadi atpakaļ |
|
Evan Huus
|
c42b7aaff2
DRY up a common producer test pattern
|
10 gadi atpakaļ |
|
Evan Huus
|
24b047c7ff
producer: bugfix for broker flushers getting stuck
|
10 gadi atpakaļ |
 Willem van Bergen
|
7661952f75
Fix producer test names.
|
10 gadi atpakaļ |
|
Willem van Bergen
|
97c8f951f2
SyncProducer’ SendMessage accepts a sarama.ProducerMessage in line with the AsyncProducer
|
10 gadi atpakaļ |
|
Willem van Bergen
|
c3befe45d0
Update example names
|
10 gadi atpakaļ |
|
Willem van Bergen
|
51060e6515
Rename Producer to AsyncProducer
|
10 gadi atpakaļ |
