無法創建內部主題 - 流線異常

Question

我想執行一個簡單的單詞計數流應用程序，但我面對的錯誤「無法創建內部主題 - 流線異常」

我已經看到了類似的線程但這似乎更像是一個網絡問題。

這是kafka經紀人未啓用安全性。

只有一個經紀人被配置，仍然是這個問題。

有人可以讓我知道如何解決這個問題嗎？

Answer 1

下面是錯誤堆棧跟蹤。

org.apache.kafka.streams.processor.internals.InternalTopicManager） [2017-07-01 22：31：33,132] WARN無法創建內部主題：無法創建主題：wordcount-lambda-example-Counts1由於這不是這個羣集的正確控制器。重試＃3（org.apache.kafka.streams.processor.internals.InternalTopicManager） [2017-07-01 22：31：33,441]警告無法創建內部主題：無法創建主題：wordcount-lambda-example-Counts1由於這不是這個羣集的正確控制器。重試＃4（org.apache.kafka.streams.processor.internals.InternalTopicManager） [2017年7月1日22：31：33567] WARN流線程[StreamThread-1]意外的狀態從PARTITIONS_REVOKED到NOT_RUNNING過渡。 （org.apache.kafka.streams.processor.internals.StreamThread） 線程「StreamThread-1」中的異常org.apache.kafka.streams.errors.StreamsException：無法創建內部主題。 在org.apache.kafka.streams.processor.internals.InternalTopicManager.makeReady（InternalTopicManager.java:81） 在org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.prepareTopic（StreamPartitionAssignor.java:628） 在org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.assign（StreamPartitionAssignor.java:382） 在org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.performAssignment（ConsumerCoordinator.java:343） 的組織。 apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader（AbstractCoordinator.java:501）

可能是我應該嘗試重新啓動Zookeeper和代理？

Answer 2

清理您的臨時卡夫卡隊列。 運行--list卡夫卡命令來查看所有隊列開始你們的名字和與-changelog & -repartition結束和手動運行刪除它們。 這一個爲我工作。

此外，檢查您的設置delete.topic.enable實際刪除發生。在1.0.0之前它不是默認設置 - 請參閱https://issues.apache.org/jira/browse/KAFKA-5384