在 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 的一部分。
我想使用正则表达式来指定 Kafka 主题以在 Apache Flink 中使用,就像 SubscribePattern
在 Apache Kafka 中一样。但是好像没有办法做到这一点!
有什么办法吗?
谢谢!
不,此功能尚不可用,但存在 JIRA 问题 FLINK-8190。
Flink 社区正在最终确定 Flink 1.4.0 版本。它可能包含在 1.4.0 中或成为 1.5.0 的一部分。