scala – Lagom的嵌入式Kafka在杀死Lagom进程一次后无法启动

发布时间：2020-12-16 18:06:40 所属栏目：安全来源：网络整理

导读：我玩过lagom- scala-word-count Activator模板,我被迫杀死了申请流程.从那以后,嵌入式kafka无法正常工作 – 这个项目和我创建的每个新项目都无法使用.我试过了：运行sbt clean,删除嵌入的Kafka数据创建全新项目(来自其他激活模板) 重新启动我的机器. 尽管

我玩过lagom- scala-word-count Activator模板,我被迫杀死了申请流程.从那以后,嵌入式kafka无法正常工作 – 这个项目和我创建的每个新项目都无法使用.我试过了：

>运行sbt clean,删除嵌入的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-dynamic-projects中的文件夹lagom-internal-meta-project-kafka.我不知道为什么它不会被自动删除.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!