Spark Streaming + Kafka:SparkException:无法找到Set的前导偏移

你需要检查两件事:

检查此主题和分区是否存在,在您的情况下主题是test-topic和分区是0.

根据你的代码,你正在尝试从偏移量0消费消息,并且可能消息从偏移量0不可用,检查你最早的偏移量并尝试从那里消费.

以下是检查最早的偏移量的命令:

sh kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list "your broker list" --topic "topic name" --time -1