我创建了一个kafka streams scala g8模板，但我注意到它只在应用程序关闭时打印。我还尝试了打印到文件，并注意到只有当应用程序被终止时文件才会更新。
https://github.com/idarlington/kafka-streams.g8/blob/master/src/main/g8/src/main/scala/%24package__packaged%24/wordcount.scala#l43
这是预期的行为吗？
我创建了一个kafka streams scala g8模板，但我注意到它只在应用程序关闭时打印。我还尝试了打印到文件，并注意到只有当应用程序被终止时文件才会更新。
https://github.com/idarlington/kafka-streams.g8/blob/master/src/main/g8/src/main/scala/%24package__packaged%24/wordcount.scala#l43
这是预期的行为吗？
1条答案
按热度按时间ig9co6j11#
正如matthias.j.sax指出的，这是Kafka的一个错误
2.0.0. 升级到2.1.0解决了。