kafka2.11命令行手动消费

Kafka 2.11是一个分布式流处理平台，它的命令行工具`kafka-console-consumer`可以用于手动消费消息。以下是手动消费的基本步骤：

1. **安装**：首先，你需要确保已经安装了Kafka，并且配置了环境变量，以便能够找到bin目录下的命令行工具。

2. **启动消费者**：打开终端，进入Kafka的bin目录下，运行以下命令启动一个默认的消费者，它会自动从所有分区消费消息：

   bin/kafka-console-consumer.sh --bootstrap-server <brokers-list> --topic <topic-name>

将 `<brokers-list>` 替换为你的Kafka集群的实际地址，如 `localhost:9092`，`<topic-name>` 替换为你想要消费的主题名。

3. **交互模式**：这个命令行工具将进入交互模式，你可以一行一行地输入消息，每行会被发送到指定主题，也可以通过Ctrl + C停止消费。

4. **设置偏移量**：如果你想从特定的消息开始消费，可以在启动命令中添加`--from-beginning`或`--offset <offset-value>`选项来指定起始位置。

5. **高级选项**：`kafka-console-consumer.sh`还有很多其他选项，比如设置消费组 (`--group <consumer-group>`)，日志级别 (`--log-level`) 和消息格式 (`--property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer` 等）。