 Evan Huus
|
733c74f30d
Refactor the producer, part 2
|
9 rokov pred |
|
Evan Huus
|
7e88a995fe
Add test for encoding failures
|
9 rokov pred |
|
Evan Huus
|
737294ce64
Fix the flakiest producer test
|
9 rokov pred |
 Maxim Vladimirsky
|
da6bc48ffa
Enhance mock broker
|
9 rokov pred |
|
Evan Huus
|
b21ab845b5
Add a custom-partitioner test
|
9 rokov pred |
|
Evan Huus
|
08ccf5e1b5
Add a test for retries during shutdow
|
10 rokov pred |
|
Evan Huus
|
a381b3667d
producer: bugfix for aggregators getting stuck
|
10 rokov pred |
|
Evan Huus
|
c42b7aaff2
DRY up a common producer test pattern
|
10 rokov pred |
|
Evan Huus
|
24b047c7ff
producer: bugfix for broker flushers getting stuck
|
10 rokov pred |
 Willem van Bergen
|
7661952f75
Fix producer test names.
|
10 rokov pred |
|
Willem van Bergen
|
97c8f951f2
SyncProducer’ SendMessage accepts a sarama.ProducerMessage in line with the AsyncProducer
|
10 rokov pred |
|
Willem van Bergen
|
c3befe45d0
Update example names
|
10 rokov pred |
|
Willem van Bergen
|
51060e6515
Rename Producer to AsyncProducer
|
10 rokov pred |
