在 Apache Flink 中使用正则表达式订阅 Kafka 主题

use regular expression to subscribe Kafka topic in Apache Flink

我想使用正则表达式来指定 Kafka 主题以在 Apache Flink 中使用,就像 SubscribePattern在 Apache Kafka 中一样。但是好像没有办法做到这一点!

有什么办法吗?

谢谢!

不,此功能尚不可用,但存在 JIRA 问题 FLINK-8190

Flink 社区正在最终确定 Flink 1.4.0 版本。它可能包含在 1.4.0 中或成为 1.5.0 的一部分。