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

Question

我刚开始使用春季集成卡夫卡。我当时正在读取文档，在入站通道适配器和消息驱动的通道适配器之间出现了混淆。有人能解释他们之间的区别吗。同样，卡夫卡的spring集成也有一些错误处理机制，比如amqp/rmq(使用dlq)的spring集成机制。

PS :我们正试图从兔子mq转移到kafka，作为in集成框架中的消息来源。

谢谢,

Answer 1

消息驱动适配器类似于rabbitmq入站适配器，因为每当主题中有记录可用时，消息就被“推入”到集成流中。

入站通道适配器使用“拉”模型，在该模型中，您按计划轮询消息。对于RabbitMQ (从5.0.1开始)有一个等价的值，但是它目前无法用XML进行配置。

某些错误处理机制

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