为春季云流卡夫卡用户设置DLQ时,可以将DLQ写入的主题进行分区吗?我有一个要求使密钥等于特定字段,并且我想知道spring-cloud-stream如何实现。

最佳答案

Kafka活页夹中的主题提供者将创建DLQ主题,并为相应的使用者主题配置相同数量的分区。当错误的消息发送到DLQ时,它随后将它们适当地发送到使用者从原始主题接收记录的同一分区。

如果要在供应方之外创建DLQ,则可能要确保创建的DLQ具有与使用者主题相同的分区数。

关于java - Spring Cloud 流的DLQ分区Kafka主题,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/53306034/

10-10 12:45