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

Question

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

PS : 我们正在尝试从 rabbit mq 转移到 kafka 作为 Spring 集成框架中的消息源

谢谢，

Answer 1

消息驱动适配器类似于 rabbitmq 入站适配器，只要主题中有记录，消息就会“推送”到您的集成流中。

入站通道适配器使用“拉”模型，您可以按计划轮询消息。 RabbitMQ 有一个等价物（自 5.0.1 起），但目前无法使用 XML 进行配置。

一些错误处理机制

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