在lagom开发环境中,使用lagomkafkastart启动kafka之后有时它会显示kafkaserver意外关闭,之后我需要运行clean命令来再次运行它。请说明这是预期的行为。
8aqjt8rx1#
如果强行关闭sbt,zookeeper数据就会损坏,则可能发生这种情况。除了运行clean命令外,还可以手动删除 target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/ 目录。这将从kafka中清除本地数据,但不会从任何其他数据库(cassandra或rdbms)中清除。如果您使用的是lagom的messagebrokerapi,那么当您重新启动服务时,它将自动从源数据库重新填充kafka主题。
target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/
1条答案
按热度按时间8aqjt8rx1#
如果强行关闭sbt,zookeeper数据就会损坏,则可能发生这种情况。
除了运行clean命令外,还可以手动删除
target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/
目录。这将从kafka中清除本地数据,但不会从任何其他数据库(cassandra或rdbms)中清除。如果您使用的是lagom的messagebrokerapi,那么当您重新启动服务时,它将自动从源数据库重新填充kafka主题。