我创建了两个WSO2企业服务总线集成项目,一个用于Kafka消息生产者,另一个用于Kafka消息消费者。我成功地在调用REST API时创建了Kafka消息生成器,并将消息放在主题上。当我创建Kafka消息消费者时,没有像Kafka这样的传输供代理监听,并且根据文档,我们需要使用IP端点来实现同样的传输。我的要求是,当消息在主题上可用时,应该在使用者处自动从主题(类似于JMS使用者)接收Kafka消息。那么我如何使用带有Kafka细节的IP端点来实现这一点呢?
有什么建议吗?
发布于 2021-11-18 07:16:21
如果您希望使用EI服务器消费Kafka主题中的消息,则需要使用Kafka入站端点。此入站端点将定期轮询来自主题的消息,轮询间隔是可配置的。有关这方面的更多信息,请参阅文档1。
1-https://docs.wso2.com/display/EI660/Kafka+Inbound+Protocol
https://stackoverflow.com/questions/70015220
复制相似问题