kafka的topic命名技巧


 

  不多說,直接上干貨!

 

 

       比如,我們給kafka的topic命名為user_r2p10

    表示user這個topic的副本因子(r)是2,分區數(p)是10。

    這樣后期在寫消費者代碼的時候,根據topic名稱就知道分區有多少個,可以很方便的設置多少個消費者線程。

 

 

 

  比如,如下

 

  前期博客,見

Kafka的3節點集群詳細啟動步驟(Zookeeper是外裝)

 

 

  然后,

  創建topic

[hadoop@master kafka_2.10-0.9.0.1]$ pwd
/home/hadoop/app/kafka_2.10-0.9.0.1
[hadoop@master kafka_2.10-0.9.0.1]$ ll
total 128
drwxr-xr-x 3 hadoop hadoop  4096 Jul 27 17:56 bin
drwxr-xr-x 2 hadoop hadoop  4096 Jul 27 19:16 config
-rw-rw-r-- 1 hadoop hadoop 19520 Jul 28 19:57 kafka.log
drwxr-xr-x 2 hadoop hadoop  4096 Jul 27 17:26 libs
-rw-r--r-- 1 hadoop hadoop 11358 Feb 12  2016 LICENSE
drwxrwxr-x 2 hadoop hadoop  4096 Jul 28 19:56 logs
-rw------- 1 hadoop hadoop 67054 Jul 27 23:28 nohup.out
-rw-r--r-- 1 hadoop hadoop   162 Feb 12  2016 NOTICE
drwxr-xr-x 2 hadoop hadoop  4096 Feb 12  2016 site-docs
[hadoop@master kafka_2.10-0.9.0.1]$ bin/kafka-topics.sh --zookeeper master:2181,slave1:2181,slave2:2181 --create --topic gold_log_r2p5 --replication-factor 2 --partitions 5
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic "gold_log_r2p5".
[hadoop@master kafka_2.10-0.9.0.1]$ 
[hadoop@master kafka_2.10-0.9.0.1]$ 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM