CODEWITHSUNDEEP
apache-kafkalagom
techagrammer
techagrammer

Reputation: 1306

Lagom Kafka Unexpected Close Error

In Lagom Dev Enviornment, after starting Kafka using lagomKafkaStart

sometimes it shows KafkaServer Closed Unexpectedly, after that i need to run clean command to again get it running.

Please suggest is this the expected behaviour.

Upvotes: 0

Views: 241

Answers (1)

Tim Moore
Tim Moore

Reputation: 9482

This can happen if you forcibly shut down sbt and the ZooKeeper data becomes corrupted.

Other than running the clean command, you can manually delete the target/lagom-dynamic-projects/lagom-internal-meta-project-kafka/ directory.

This will clear your local data from Kafka, but not from any other database (Cassandra or RDBMS). If you are using Lagom's message broker API, it will automatically repopulate the Kafka topic from the source database when you restart your service.

Upvotes: 1

Related Questions