在Lagom Dev Enviornment中,使用lagomKafkaStart启动Kafka之后
有时它显示KafkaServer意外关闭,之后我需要运行clean命令再次运行它 .
请建议这是预期的行为 .
如果你强行关闭sbt并且ZooKeeper数据被破坏,就会发生这种情况 .
除了运行clean命令外,您还可以手动删除 target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/ 目录 .
target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/
这将清除Kafka的本地数据,但不会清除任何其他数据库(Cassandra或RDBMS) . 如果您使用的是Lagom的消息代理API,则在重新启动服务时,它将自动从源数据库重新填充Kafka主题 .
1 回答
如果你强行关闭sbt并且ZooKeeper数据被破坏,就会发生这种情况 .
除了运行clean命令外,您还可以手动删除
target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/
目录 .这将清除Kafka的本地数据,但不会清除任何其他数据库(Cassandra或RDBMS) . 如果您使用的是Lagom的消息代理API,则在重新启动服务时,它将自动从源数据库重新填充Kafka主题 .