Я создал шаблон scala g8 для kafka streams, но заметил, что он печатается только когда приложение убито.Я также попытался распечатать в файл и заметил, что файл обновляется только после завершения работы приложения.
https://github.com/idarlington/kafka-streams.g8/blob/master/src/main/g8/src/main/scala/%24package__packaged%24/WordCount.scala#L43
Это ожидаемое поведение?
Как указал Matthias.J.Sax , это ошибка в Kafka 2.0.0.Обновление до 2.1.0 разрешено.
2.0.0
2.1.0