我想知道apachekafka是否可以通信并向jms发送消息?我能在他们之间建立联系吗?例如,我在系统中使用jms,它应该向使用kafka的另一个系统发送消息
kcrjzv8t1#
如果要求与上一答案相反:Kafka生产者->Kafka经纪人->jms经纪人->jms消费者然后你需要一个kafkaconnect接收器,就像下面data mountaineer的接收器一样http://docs.datamountaineer.com/en/latest/jms.html
csbfibhn2#
回答有点晚,但如果我理解正确的要求。如果需求是来自客户机->jms->kafka--->消费者的同步消息传递,那么下面不是解决方案,但是如果它(很可能)是异步需求,比如:客户->jms |--->kafka--->消费者那么,这就涉及到Kafka如何与Kafka整合不同的源和汇的问题。http://docs.confluent.io/2.0.0/connect/http://www.confluent.io/product/connectors所以你需要的是一个jmssourceconnector。
2条答案
按热度按时间kcrjzv8t1#
如果要求与上一答案相反:
Kafka生产者->Kafka经纪人->jms经纪人->jms消费者
然后你需要一个kafkaconnect接收器,就像下面data mountaineer的接收器一样
http://docs.datamountaineer.com/en/latest/jms.html
csbfibhn2#
回答有点晚,但如果我理解正确的要求。
如果需求是来自客户机->jms->kafka--->消费者的同步消息传递,那么下面不是解决方案,但是如果它(很可能)是异步需求,比如:
客户->jms |--->kafka--->消费者
那么,这就涉及到Kafka如何与Kafka整合不同的源和汇的问题。
http://docs.confluent.io/2.0.0/connect/http://www.confluent.io/product/connectors
所以你需要的是一个jmssourceconnector。