获取无法识别的选项：--执行时的主题 ReadFromKafka.java

Question

我在执行 ReadFromKafka.java

时出现以下错误

来源可在 https://github.com/dataArtisans/kafka-example/blob/master/src/main/java/com/dataartisans/ReadFromKafka.java

Unrecognized option: --topic Error: Could not create the Java Virtual Machine. Error: A fatal exception has occurred. Program will exit.

我提供了以下参数：

--topic test --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --group.id myGroup

我按照以下步骤操作 http://data-artisans.com/kafka-flink-a-practical-how-to/

提前致谢

~SC

Answer 1

您打算如何开始示例？来自 IDE?

如果是，您确定将参数放入 "program arguments" 部分，而不是 JVM 参数吗？

Answer 2

调用 jar 时出现问题。

尝试这样的事情

java -jar myjar.jar "--题目测试--bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --group.id我的组

Answer 3

我遇到了这种情况，因为没有包含 kafka 代码的有效 jar 文件。由于未找到有效的 jar，CLASS_PATH 变量在 bin/kafka-run-class.sh 中为空。那个 shell 脚本可能应该检查那个条件和 return 一个更好的错误，相反，它只是在它正在组装的 java 命令中留下一个无效的 -cp 标志。这会导致您（我们）看到的错误消息吐出 java 使用信息（因为 -cp 后面没有任何内容是无效的）。

我的解决方案是使用 gradlew jar.

构建 kafka 源

此问题的根源在于文档希望您运行来自实际的 kafka 安装，而不是来自 src 目录。

获取无法识别的选项：--执行时的主题 ReadFromKafka.java

Getting Unrecognized option: --topic while executing ReadFromKafka.java

apache-kafka

apache-flink