我是流媒体社区的新手，我正在尝试使用Kafka topics和flink创建一个连续查询，但是我还没有找到任何例子，所以我可以得到一个如何开始的想法，你能帮我举一些例子吗？谢谢。
yyyllmsg1#
对于你的用例，我猜你想使用Kafka作为连续数据的来源。在这种情况下，你可以使用Kafka源连接器（链接如下），如果你想随着时间切片，你可以使用flink的窗口处理函数。这将分组你的Kafka消息流在一个特定的时间框架，像一个列表/Map。Flink Kafka source connectorFlink Window Processing Function
1条答案
按热度按时间yyyllmsg1#
对于你的用例，我猜你想使用Kafka作为连续数据的来源。在这种情况下，你可以使用Kafka源连接器（链接如下），如果你想随着时间切片，你可以使用flink的窗口处理函数。这将分组你的Kafka消息流在一个特定的时间框架，像一个列表/Map。
Flink Kafka source connector
Flink Window Processing Function