我正在探索 Kafka Streams 的 session 化用例，并想了解如果更早看到结束信号，是否有办法在不活动间隙之前结束 session 窗口？ 感谢任何帮助。
最佳答案
I'm exploring Kafka Streams for a sessionization use case and wanted to understand if there is a way to end a session window earlier than the inactivity gap if it sees an end signal earlier ?
不，这不可能开箱即用。 KStreams 中的 session 窗口实现使用不活动状态作为唯一参数来确定窗口( session )是否应该关闭。
如果您需要不同的行为，您可以使用 Kafka Streams 的处理器 API。例如，我见过开发人员基于有限状态机实现自定义“ session ”。例如，可以通过这种方式从原始网络数据重建 TCP/IP session 。
关于apache-kafka-streams - 看到结束信号时结束 session 窗口，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59418298/