?

　　不多說(shuō)，直接上干貨！

?

?

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

　　　　表示user這個(gè)topic的副本因子（r）是2，分區(qū)數(shù)（p）是10。

　　　　這樣后期在寫(xiě)消費(fèi)者代碼的時(shí)候，根據(jù)topic名稱(chēng)就知道分區(qū)有多少個(gè)，可以很方便的設(shè)置多少個(gè)消費(fèi)者線程。

?

?

?

　　比如，如下

?

　　前期博客，見(jiàn)

Kafka的3節(jié)點(diǎn)集群詳細(xì)啟動(dòng)步驟（Zookeeper是外裝）

?

?

　　然后，

　　創(chuàng)建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]$

?

轉(zhuǎn)載于:https://www.cnblogs.com/zlslch/p/7246749.html

《新程序員》：云原生和全面數(shù)字化實(shí)踐50位技術(shù)專(zhuān)家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的kafka的topic命名技巧的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。