其他分享
首页 > 其他分享> > kafka的简单实用

kafka的简单实用

作者:互联网

命令行方式

  1. 创建一个主题
[root@manager129 kafka_2.12-2.8.0]# ./bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic heima -partitions 2 --replication-factor 1
Created topic heima.
  1. 展示所有主题
    命令:
[root@manager129 kafka_2.12-2.8.0]# ./bin/kafka-topics.sh --zookeeper localhost:2181 --list
heima
  1. 查看主题详情
    命令:
[root@manager129 kafka_2.12-2.8.0]# ./bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic heima
Topic: heima    TopicId: D0rctcUJQ-2-1QstiUHw6w PartitionCount: 2       ReplicationFactor: 1    Configs: 
        Topic: heima    Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: heima    Partition: 1    Leader: 0       Replicas: 0     Isr: 0
  1. 启动消费者服务
    命令:
[root@manager129 kafka_2.12-2.8.0]# ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic heima
> hello
  1. 启动生产者服务
    命令:
[root@manager129 kafka_2.12-2.8.0]# ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic heima
>hello

标签:topic,heima,--,zookeeper,kafka,实用,2.8,简单
来源: https://www.cnblogs.com/zhuxiang1633/p/14939285.html