kafka 流应用程序仅在应用程序被杀死时打印

Question

我创建了一个 kafka 流 scala g8 模板，但我注意到它仅在应用程序被终止时打印。我还尝试了打印到文件，发现文件只有在应用程序被终止时才会更新。

https://github.com/idarlington/kafka-streams.g8/blob/master/src/main/g8/src/main/scala/%24package__packaged%24/WordCount.scala#L43

这是预期的行为吗？

Answer 1

正如Matthias.J.Sax 所指出的，这是Kafka 2.0.0 中的一个错误。升级到2.1.0 解决了它。