当为spring-cloud-stream Kafka消费者设置DLQ时,DLQ写入的主题可以分区吗?我需要使 key 等于特定字段,我想知道 spring-cloud-stream 如何实现这一点。
最佳答案
Kafka 绑定(bind)器中的主题配置器将创建 DLQ 主题,并为相应的消费者主题配置相同数量的分区。当错误的消息发送到 DLQ 时,DLQ 会适本地将它们发送到消费者从原始主题接收记录的同一分区。
如果您在配置程序之外创建 DLQ,您可能需要确保创建的 DLQ 具有与使用者主题相同的分区数。
关于java - spring-cloud-stream DLQ 的分区 Kafka 主题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53306034/