3.Kafka常用命令

版本&＃xff1a;kafka_2.13-2.8.0

bin/kafka-topics.sh --list --bootstrap-server hadoop201:9092

bin/kafka-topics.sh --create --bootstrap-server hadoop201:9092 --topic firstTopic

也可以在创建 topic 时&＃xff0c;手动方式指定分区数、副本数

bin/kafka-topics.sh --create --bootstrap-server hadoop201:9092 --replication-factor 2 --partitions 3 --topic firstTopic
 
备注&＃xff1a;
  replication-factor 2   备份数(2个备份)
  partitions 3   分区数(3个分区)
  topic firstTopic   firstTopic为topic的名称

bin/kafka-topics.sh --describe --topic firstTopic --bootstrap-server hadoop201:9092

[hadoop&＃64;hadoop201 kafka]$ bin/kafka-topics.sh --describe --topic firstTopic --bootstrap-server hadoop201:9092
Topic: firstTopic TopicId: n0-rqoLVQkqsriiCElr4mw PartitionCount: 1 ReplicationFactor: 3 Configs: segment.bytes&＃61;1073741824Topic: firstTopic Partition: 0 Leader: 2 Replicas: 2,1,0 Isr: 2,1,0

4、删除topic

bin/kafka-topics.sh --delete --bootstrap-server hadoop201:9020 --topic firstTopic

• 老版本&＃xff1a;需要server.properties中设置delete.topic.enable&＃61;true&＃xff0c;否则只是标记删除或者直接重启。
• 新版本&＃xff1a;已经没有delete.topic.enable&＃61;true这个配置&＃xff0c;可以直接删除 topic 了。如果有生产者或者消费者在使用该topic&＃xff0c;需要停掉生产者或者消费者才能进行删除&＃xff09;

bin/kafka-console-producer.sh --topic firstTopic --bootstrap-server hadoop201:9092

备注&＃xff1a;

  kafka01&＃xff1a;主机名(通过vi /etc/sysconfig/network&＃xff0c;修改hostname即可&＃xff0c;此处可填IP地址)
  orderMq&＃xff1a;为topic的名称

bin/kafka-console-consumer.sh --topic firstTopic --from-beginning --bootstrap-server hadoop201:9092

备注&＃xff1a;
--from-beginning&＃xff1a;会把主题中以往所有的数据都读取出来。即&＃xff1a;从头开始读

7、查看消费位置

1.使用 --all-groups查看所有组
bin/kafka-consumer-groups.sh --bootstrap-server hadoop201:9092 --describe --all-groups
 
2.使用 --group 查看指定组
bin/kafka-consumer-groups.sh --bootstrap-server hadoop201:9092 --describe --group 组名

bin/kafka-topics.sh --bootstrap-server hadoop201:9092 --alter --topic firstTopic --partitions 6