不多说,直接上干货!

       比如,我们给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]$ 

转载于:https://www.cnblogs.com/zlslch/p/7246749.html

kafka的topic命名技巧相关推荐

  1. Kafka中topic的Partition,Kafka为什么这么快,Consumer的负载均衡及consumerGroup的概念(来自学习笔记)

    1.1. Kafka中topic的Partition  在Kafka文件存储中,同一个topic下有多个不同partition,每个partition为一个目录,partiton命名规则为topic ...

  2. kafka专题:kafka的Topic主题、Partition分区、消费组偏移量offset等基本概念详解

    文章目录 1. kafka集群整体架构 2. kafka相关元素的基本概念 2.1 主题Topic和分区Partition 2.2 kafka消息存储在哪里? 2.3 分区副本 2.4 消费组和偏移量 ...

  3. Kafka主题(Topic)的管理

    主题的管理包括创建主题. 查看主题信息.修改主题和删除主题等操作.可以通过 Kafka 提供的 kafka-topics.sh 脚本来执行这些操作,这个脚本位于 $KAFKA_HOME/bin/目录下 ...

  4. Kafka学习笔记:Kafka的Topic、Partition和Message

    Kafka的Topic和Partition Topic Topic是Kafka数据写入操作的基本单元,可以指定副本 一个Topic包含一个或多个Partition,建Topic的时候可以手动指定Par ...

  5. kafka 清除topic数据脚本

    原 kafka 清除topic数据脚本 2018年07月25日 16:57:13 pete1223 阅读数:1028 #!/bin/sh param=$1 echo "=========== ...

  6. kafka delete topic,marked for deletion

    kafka 删除topic 提示marked for deletion [root@logSer config]# kafka-topics.sh --delete --zookeeper local ...

  7. 指定输出路径_新手Python必须知道的文件路径和变量命名技巧

    文件路径操作 在进行数据处理或自动化办公时,常常需要进行文件路径操作,比如:从电脑本地导入数据文件,将绘制的图片保存到本地硬盘等. 1. 绝对路径和相对路径 绝对路径就是从根目录开始索引,比如: I: ...

  8. 【kafka】Kafka中Topic级别配置

    1.概述 Kafka中topic级别配置 1.1 Topic级别配置 配置topic级别参数时,相同(参数)属性topic级别会覆盖全局的,否则默认为全局配置属性值. 创建topic参数可以设置一个或 ...

  9. kafka删除topic及其相关数据

    1.删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录 2.Kafka 删除topic ...

最新文章

  1. Python游戏开发,Pygame模块,Python从零开始带大家实现魔塔小游戏
  2. grape动态PHP结构(三)——API接口
  3. 人工智能除了创造新材料还能预测化学反应性能
  4. python自动化办公 百度网盘-Python自动化办公实战教程2020最新带源码
  5. LeetCode Algorithm 102. 二叉树的层序遍历
  6. 10个顶级的CSS3代码生成器
  7. 【渝粤教育】 国家开放大学2020年春季 1259西方行政学说 参考试题
  8. Reddit热议被引最多的机器学习论文:上世纪LSTM称霸,何恺明今年被引1.8w居首...
  9. 深度学习(四十二)word2vec词向量学习笔记
  10. 阶段3 2.Spring_06.Spring的新注解_5 spring的新注解-PropertySource
  11. Java中字符串的拼接和转义
  12. 代码整洁之道1-6章总结
  13. 我与刘强东的故事:他的1000亿和我的5000万(转超级表格)
  14. ueditor限制字数长度与加入提示语
  15. 电类专业(自动化、电气、电子、电力、通信等)的大学四年应该怎么过呢_史蒂文森sun_新浪博客
  16. 【提供代码获取方式】matlab使用风羽法画大气环流
  17. Python的学习(二十一)----Python的静态变量
  18. 网络拓扑测绘之城域网拓扑
  19. 计算机玩游戏不能全屏,电脑游戏不能全屏怎么办 电脑游戏不能全屏的解决方法...
  20. R语言基于决策树的银行信贷风险预警模型

热门文章

  1. 安全绳使用方法图解_电暖器的使用方法与安全注意事项
  2. js运动动画的八个知识点
  3. Android之自定义Adapter的ListView
  4. ACM 模板--邻接表 无向图 搜索算法
  5. oracle12基本操作
  6. 常考数据结构与算法:两数之和
  7. redhat配置dns服务器bind
  8. 一眼毁三观:JS中令人发指的valueOf方法
  9. 集体终止合作 航空代理模式走投无路背后
  10. 开启虚拟化技术之旅---1什么是虚拟化?