我玩过 lagom-scala-word-count
Activator 模板,我被迫终止了应用程序进程。从那以后嵌入式 kafka 不起作用 - 这个项目和我创建的每个新项目都无法使用。我试过了:
尽管如此,我还是无法让 Lagom 工作。在第一次启动期间,我在日志中看到以下几行:
[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 1 : {wordCount=LEADER_NOT_AVAILABLE}
[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 2 : {wordCount=LEADER_NOT_AVAILABLE}
[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 4 : {wordCount=LEADER_NOT_AVAILABLE}
[warn] a.k.KafkaConsumerActor - Consumer interrupted with WakeupException after timeout. Message: null. Current value of akka.kafka.consumer.wakeup-timeout is 3000 milliseconds
[warn] a.k.KafkaConsumerActor - Consumer interrupted with WakeupException after timeout. Message: null. Current value of akka.kafka.consumer.wakeup-timeout is 3000 milliseconds
下一次发布的结果是:
[info] Starting Kafka
[info] Starting Cassandra
....Kafka Server closed unexpectedly.
....
[info] Cassandra server running at 127.0.0.1:4000
我已经在 https://gist.github.com/szymonbaranczyk/a93273537b42aafa45bf67446dd41adb 上发布了来自 lagom-internal-meta-project-kafka 的完整 server.log 。
是否有可能某些损坏的嵌入式 Kafka 数据全局存储在我的电脑上并导致这种情况?
最佳答案
为了将来引用,正如 James 在评论中提到的,您必须删除 lagom-internal-meta-project-kafka
中的文件夹 target/lagom-dynamic-projects
。我不知道为什么它不会被自动删除。