kafka2:經常使用topic命令

經常使用操做

建立一個topic

bin/kafka-topics.sh --create --zookeeper 192.168.3.230:2181 --replication-factor 3 --partitions 1 --topic test-topic
–topic指定topic name
–partitions指定分區數,這個參數須要根據broker數和數據量決定,正常狀況下,每一個broker上兩個partition最好;
–replication-factor指定partition的replicas數,建議設置爲2;code

查看建立的topic

bin/kafka-topics.sh --describe --zookeeper 192.168.3.230:2181 --topic test-topic
Topic:test-replicated-topic PartitionCount:1 ReplicationFactor:3 Configs:
Topic: test-replicated-topic Partition: 0 Leader: 1 Replicas: 1,2,0 Isr: 1,2,0server

查看topic列表及具體信息<

bin/kafka-topics.sh --describe --zookeeper 192.168.3.230 :2181kafka

建立消息

bin/kafka-console-producer.sh --broker-list 192.168.3.234:9092 --topic test-topicit

消費消息

bin/kafka-console-consumer.sh --zookeeper 192.168.3.234:2181 --from-beginning --topic test-topicio

程序自動建立

開啓自動建立配置:auto.create.topics.enable=true
使用程序直接往kafka中相應的topic發送數據,若是topic不存在就會按默認配置進行console

kafka刪除topic方法

  1. 添加配置:
    ${kafka_home}/config/server.properties
    delete.topic.enable=true
  2. 重啓kafka server:
    ${kafka_home}/bin/kafka-server-start.sh ~/kafka/config/server.properties
  3. 刪除指定topic
    ${kafka_home}/bin/kafka-topics.sh \--delete \--zookeeper localhost:2181 \--topic daemon12
相關文章
相關標籤/搜索