org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: --zookeeper
时间: 2024-11-25 08:13:21 浏览: 19
kafka处理超大消息的配置 org.apache.kafka.common.errors.RecordTooLargeException
`ConfigException` 是Apache Kafka库中用于表示配置错误的一个异常。当你试图通过命令行启动Kafka生产者(`kafka-console-producer.sh`)或消费者(`kafka-console-consumer.sh`)时,如果`bootstrap.servers` 参数包含了无效的URL(如`--zookeeper`),Kafka会抛出这个异常,因为它期望的是一个或多个服务器地址,而不是Zookeeper的相关参数。
具体来说,`bootstrap.servers` 应该指定Kafka集群的Broker列表,而不是Zookeeper的服务地址。例如,在命令行中,应该这样设置:
- 对于生产者:
```bash
kafka-console-producer.sh --broker-list 192.168.0.82:9092 --topic test
```
- 对于消费者:
```bash
kafka-console-consumer.sh --topic test --bootstrap-server 192.168.0.82:9092
```
如果你确实需要与Zookeeper交互,你应该使用不同的选项,比如在生产者中使用`--zookeeper-url` 或消费者中使用`--zookeeper-connect` 来指定Zookeeper连接信息。
阅读全文