lagom kafka意外关闭错误

oaxa6hgo  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(371)

在lagom开发环境中,使用lagomkafkastart启动kafka之后
有时它会显示kafkaserver意外关闭,之后我需要运行clean命令来再次运行它。
请说明这是预期的行为。

8aqjt8rx

8aqjt8rx1#

如果强行关闭sbt,zookeeper数据就会损坏,则可能发生这种情况。
除了运行clean命令外,还可以手动删除 target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/ 目录。
这将从kafka中清除本地数据,但不会从任何其他数据库(cassandra或rdbms)中清除。如果您使用的是lagom的messagebrokerapi,那么当您重新启动服务时,它将自动从源数据库重新填充kafka主题。

相关问题