可能重复,如果可以,请指导我。我试图将IBM MQ读入Apache Kafka并对其进行解析。我尝试使用Python库(PYMQI),但对使用python的Kafka / spark-streaming更感兴趣。
您不需要中间的Kafka来直接从IBM MQ流处理数据。您可以使用以下Spark Connector以流方式处理消息。您也可以参考following tutorial系列文章中的操作方法。
https://github.com/srnghn/spark-mq-receiver