我正在做一个poc,我们需要连接rabbitmq和kafka。我的问题是拉比MQ和Kafka之间是否有联系?提前谢谢
lf5gs5x21#
简言之,是的,它可以连接拉比MQ和Kafka。有两种方法可以实现。jcustenborder的开源kafka连接器https://github.com/jcustenborder/kafka-connect-rabbitmq合并企业许可证版本下的rabbitmq kafka连接器。https://docs.confluent.io/current/connect/kafka-connect-rabbitmq/index.html如何安装那些Kafka连接器来达到目的?对于开源连接器,构建项目,然后获取jar文件或从maven repo下载,并将jar文件放在路径usr/share/java的kafka连接器插件(docker)中。然后重新启动插件或docker容器。对于合流下的rabbitmq-kafka连接器,请按照网页中的说明进行操作。注意:来自jcustenborder的kafka connect rabbitmq git repo不可用。但是maven repo和forked off repository可用https://mvnrepository.com/artifact/com.github.jcustenborder.kafka.connect/kafka-connect-rabbitmqhttps://github.com/osterzel/kafka-connect-rabbitmq
1条答案
按热度按时间lf5gs5x21#
简言之,是的,它可以连接拉比MQ和Kafka。有两种方法可以实现。
jcustenborder的开源kafka连接器https://github.com/jcustenborder/kafka-connect-rabbitmq
合并企业许可证版本下的rabbitmq kafka连接器。https://docs.confluent.io/current/connect/kafka-connect-rabbitmq/index.html
如何安装那些Kafka连接器来达到目的?
对于开源连接器,构建项目,然后获取jar文件或从maven repo下载,并将jar文件放在路径usr/share/java的kafka连接器插件(docker)中。然后重新启动插件或docker容器。
对于合流下的rabbitmq-kafka连接器,请按照网页中的说明进行操作。
注意:来自jcustenborder的kafka connect rabbitmq git repo不可用。但是maven repo和forked off repository可用
https://mvnrepository.com/artifact/com.github.jcustenborder.kafka.connect/kafka-connect-rabbitmq
https://github.com/osterzel/kafka-connect-rabbitmq