bin/kafka-console-consumer.sh \ --bootstrap-server hadoop102:9092 --from-beginning --topic topic_log Missing required argument "[bootstrap-server]" Option Description ------ ----------- --bootstrap-server <String: server to REQUIRED: The server(s) to connect to. connect to> --consumer-property <String: A mechanism to pass user-defined consumer_prop> properties in the form key=value to
时间: 2024-02-10 13:21:27 浏览: 236
这是一个 Kafka 命令行工具的使用示例,用于消费指定 topic 的消息。其中:
- `--bootstrap-server` 参数指定了 Kafka 集群的地址,这里指定了单个 broker 的地址 `hadoop102:9092`,也可以指定多个地址以逗号分隔,例如 `host1:port1,host2:port2`。
- `--from-beginning` 参数表示从该 topic 最早的消息开始消费,如果不设置该参数,则只消费接收到命令之后发布的消息。
- `--topic` 参数指定了要消费的 topic 的名称。
- `--consumer-property` 参数可以用来传递一些自定义的消费者属性。
请问你有什么问题需要我解答吗?
阅读全文