【发布时间】：2018-10-17 03:46:30
【问题描述】：
我想将100 messages/second 从我的流中发送到 kafka 主题。我有足够多的数据流来执行此操作。
到目前为止，我已经找到了窗口化概念，但我无法将其修改为我的用例。
【问题讨论】：
标签： apache-kafka stream apache-flink
【发布时间】：2018-10-17 03:46:30
【问题描述】：
您可以使用ProcessFunction 轻松完成此操作。您可以将计数器保持在 Flink 状态，并且仅在计数器小于 100 时才发出元素。同时，使用计时器每秒将计数器重置为零一次。
【讨论】：