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

Question

当为spring-cloud-stream Kafka消费者设置DLQ时，DLQ写入的主题可以分区吗？我需要使密钥等于特定字段，我想知道 spring-cloud-stream 怎么可能。

Answer 1

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

如果您在供应商之外创建 DLQ，您可能需要确保创建的 DLQ 具有与使用者主题相同数量的分区。