Spring 集成 Kafka：入站通道适配器与消息驱动适配器

Question

我是 spring 集成 kafka 的新手。我在阅读文档时，对入站通道适配器和消息驱动的通道适配器感到困惑。有人能解释一下它们之间的区别吗？ spring kafka 集成也有一些错误处理机制，例如 spring 集成 amqp/rmq（使用 dlq）中存在的错误处理机制。

PS：我们正在尝试从 rabbit mq 转移到 kafka 作为 spring 集成框架

中的消息源

谢谢，

Answer 1

消息驱动适配器类似于 rabbitmq 入站适配器，只要主题中有可用记录，消息就会 "pushed" 进入您的集成流。

入站通道适配器使用 "pull" 模型，您可以在其中按计划轮询消息。 RabbitMQ 有一个等效项（自 5.0.1 起），但目前无法使用 XML.

配置

some error handling mechanism

SIK 组件是与所有其他 SI 组件相同的 类 的子类，因此通常可以使用相同的设施，是的。