首页 > 解决方案 > 如何理解 Kafka HA?

问题描述

我认为在有多个分区的主题中,如果其中一个分区不可用,其他分区仍然可以正常消费。这个对吗?

如果是这样,为什么我Spark Streaming在其中一个分区不可用时启动程序时会报告此错误?

Timeout of 60000ms expired before the position for partition [topic_name]-[partition] could be determined

一些例外

标签: apache-kafkaspark-streaming

解决方案


推荐阅读