我打算将数据管道遵循一项要求之一。
IBM MQ-> kafka connect-> flink-> mongodb
Flink实时流媒体是执行过滤，应用业务规则和丰富传入记录。
IBM MQ部分是无法更改的旧组件。
可能会使用Confluent或Cloudera平台来容纳Kafka和Flink的部分。
我可以在上述方法上使用一些想法/建议。
我会仔细研究您是否真的需要Kafka Connect。我相信IBM MQ支持JMS，并且在Apache Bahir中有一个JMS兼容连接器：>