我用它来消耗数据:
kafka-console-consumer.sh--引导服务器kafka01:9092--主题测试--consumer.config/test/kafka/config/consumer.properties
consumer.properties文件具有以下设置:
[...]
bootstrap.servers=kafka01:9092、kafka02:9092、kafka03:9092
[...]
所以我在问bootstrap.server的优先顺序是什么?引导服务器最终将是什么?:
仅kafka01:9092(使用参数“--bootstrap sever”指定)?或者在consumer.properties文件中指定的kafka01:9092、kafka02:9092、kafka03:9092?
谢谢!
2条答案
按热度按时间7y4bm7vi1#
正如mike所建议的,我在引导服务器中提供了一个错误的地址,kafka显示了一个警告:无法解析错误的服务器
所以问题回答了,配置文件并不优先于选项的cli参数
--引导服务器
fdbelqdn2#
答案也在源代码中得到了证实
ConsoleConsumer
我们在哪里所以你可以看到它使用
consumerProps
首先是通过配置文件提供的,然后是extraConsumerProps
以下是作为命令行参数提供的参数: