When a handler returns an error for a message, the consumer triggers the publishing to retry queues with only the payload and misses adding the headers and key (latter used for partitioning sometimes).
|
_, _, err := p.producer.SendMessage(&sarama.ProducerMessage{ |
|
Topic: f.NextTopic, |
|
Value: sarama.ByteEncoder(f.Message), |
|
}) |
When a handler returns an error for a message, the consumer triggers the publishing to retry queues with only the payload and misses adding the headers and key (latter used for partitioning sometimes).
kafka-consumer-go/kafka_producer.go
Lines 86 to 89 in 6b40b35