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