Kafka消费者

1. 消费者命令参数

参数	描述
--bootstrap-server <String: server toconnect to>	连接的 Kafka Broker 主机名称和端口号
--topic <String: topic>	操作的 topic 名称

2. 消费消息

[jack@hadoop106 kafka-3.6.1]$ ./bin/kafka-console-consumer.sh --bootstrap-server 192.168.101.107:9092 -topic hadoop
hello
## 如果需要从头消费消息, --from-beginning
[jack@hadoop106 kafka-3.6.1]$ ./bin/kafka-console-consumer.sh --bootstrap-server 192.168.101.107:9092 -topic hadoop --from-beginning
I am a test
hello

3. Kafka 消费方式

• pull(拉)模 式：
  consumer采用从broker中主动拉取数据。Kafka采用这种方式。
• push(推)模式：
  Kafka没有采用这种方式，因为由broker决定消息发送速率，很难适应所有消费者的消费速率。例如推送的速度是50m/s，Consumer1、Consumer2就来不及处理消息。pull模式不足之处是，如 果Kafka没有数据，消费者可能会陷入循环中，一直返回空数据。