| .. |
|
async_producer.go
|
a468f3ae10
Make Partition and Offset normal struct fields instead of functions.
|
11 lat temu |
|
async_producer_test.go
|
51060e6515
Rename Producer to AsyncProducer
|
11 lat temu |
|
consumer.go
|
abfb8a5a6f
Add tests for channel draining expectations.
|
11 lat temu |
|
consumer_test.go
|
abfb8a5a6f
Add tests for channel draining expectations.
|
11 lat temu |
|
mocks.go
|
532c0656d3
OnPartition -> ExpectConsumePartition.
|
11 lat temu |
|
sync_producer.go
|
97c8f951f2
SyncProducer’ SendMessage accepts a sarama.ProducerMessage in line with the AsyncProducer
|
11 lat temu |
|
sync_producer_test.go
|
97c8f951f2
SyncProducer’ SendMessage accepts a sarama.ProducerMessage in line with the AsyncProducer
|
11 lat temu |
Willem van Bergen
97c8f951f2
SyncProducer’ SendMessage accepts a sarama.ProducerMessage in line with the AsyncProducer