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

标签 java spring-cloud-stream spring-kafka

当为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/

相关文章:

java - 创建客户端-服务器聊天程序

java - Spring Cloud Stream Kinesis Binder - 并发

java - 为什么 Spring Integration 消息方法处理行为在默认 Spring Cloud Stream 配置中发生了变化

java - 将 kafka 日志消息重定向到单独的日志(catalina.out 除外)

java - 将 jPCT 与 Vuforia/QCAR SDK 集成

java - HttpServletRequestWrapper 在 Spring 4 下不工作

java - 如何确认 spring kafka 中的当前偏移量以进行手动提交

docker - Spring Boot Kafka消息使用者和丢失的消息

java - 使用递归求和

docker - 如何更改 Spring Cloud Stream Kafka binder 的目标?