spring-cloud-stream 的 DLQ 分区 Kafka 主题

Question

当为spring-cloud-stream Kafka消费者设置DLQ时，DLQ写入的topic是否可以分区？我需要使密钥等于特定字段，我想知道如何使用 spring-cloud-stream 实现这一点。

Answer 1

Kafka binder 中的主题供应器将创建 DLQ 主题，并为相应的消费者主题配置相同数量的分区。当错误的消息被发送到 DLQ 时，它会适当地将它们发送到消费者从原始主题接收记录的同一分区。

如果您在配置器外部创建 DLQ，您可能需要确保创建的 DLQ 的分区数与消费者主题的分区数相同。