无法创建内部主题 - 流线异常

问题描述：

我想执行一个简单的单词计数流应用程序，但我面对的错误“无法创建内部主题 - 流线异常”无法创建内部主题 - 流线异常

我已经看到了类似的线程但这似乎更像是一个网络问题。

这是kafka经纪人未启用安全性。

只有一个经纪人被配置，仍然是这个问题。

有人可以让我知道如何解决这个问题吗？

您可以粘贴错误内容吗？通常情况下会发生这种情况，如果内部主题存在坏配置已经像预期的分区号不同。完整的错误会告诉我们更好的。 – dawsaw

答

下面是错误堆栈跟踪。

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和代理？

答

清理您的临时卡夫卡队列。运行--list卡夫卡命令来查看所有队列开始你们的名字和与-changelog & -repartition结束和手动运行删除它们。这一个为我工作。

此外，检查您的设置delete.topic.enable实际删除发生。在1.0.0之前它不是默认设置 - 请参阅https://issues.apache.org/jira/browse/KAFKA-5384

无法创建内部主题 - 流线异常

相关推荐