kafka启动、kafka查看、创建topic的命令_yrc_Note的博客-CSDN博客_kafka新增topic

本站和网页 https://blog.csdn.net/yrc_Note/article/details/99704440 的作者无关，不对其内容负责。快照谨为网络故障时之索引，不代表被搜索网站的即时页面。

kafka启动、kafka查看、创建topic的命令_yrc_Note的博客-CSDN博客_kafka新增topic
kafka启动、kafka查看、创建topic的命令
yrc_Note
于 2019-08-18 15:24:01 发布
38736
收藏
33
分类专栏：
kafka
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/yrc_Note/article/details/99704440
版权
kafka
专栏收录该内容
1 篇文章
0 订阅
订阅专栏
这里目前只是记录了我使用过的操作，所以并不完整。
一、kafka启动（linux环境）
1、单节点启动（非集群）
（1）下载kafka安装包http://kafka.apache.org/downloads，我这里下载的是kafka_2.11-2.3.0.tgz 
（2）解压（不需要安装，直接配置可用） tar -xzvf kafka_2.11-2.3.0.tgz
（3）对于单节点kafka，我们配置很简单，只需在.../kafka_2.11-2.3.0/config 目录下修改/kafka_2.11-2.3.0/config/server.properties这个配置文件的内容，只需取消#listeners=PLAINTEXT://:9092的注释，或者重新加一行listeners=PLAINTEXT:[本设备的ip]//:9092，最中修改的结果为listeners=PLAINTEXT:[本设备的ip]//:9092
（4）启动zookeeper：.../kafka_2.11-2.3.0/bin/zookeeper-server-start.sh -daemon .../kafka_2.11-2.3.0/config/zookeeper.properties
（5）启动kafka：.../kafka_2.11-2.3.0/bin/kafka-server-start.sh -daemon .../kafka_2.11-2.3.0/config/server.properties
（6）启动完成
2、集群启动
后面在补充吧~~，下面记录使用过的命令
二、常用命令
1、创建topic：bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181 
--topic 指定topic名字
--replication-factor 指定副本数，因为我的是集群环境，这里副本数就为3
--partitions 指定分区数，这个参数需要根据broker数和数据量决定，正常情况下，每个broker上两个partition最好
方法二： 开启自动创建配置：auto.create.topics.enable=true  使用程序直接往kafka中相应的topic发送数据，如果topic不存在就会按默认配置进行创建。  
2、查看有哪些topic：bin/kafka-topics.sh --list --zookeeper localhost:2181
3、查看具体的topic详细信息：bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic lx_test_topic --describe
[root@sdn kafka]# bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic xxx-kafka-topic --describe
Topic:xxx-kafka-topic PartitionCount:1 ReplicationFactor:1 Configs:
Topic: xxx-kafka-topic Partition: 0 Leader: 0 Replicas: 0 Isr: 0
yrc_Note
关注
关注
10
点赞
33
收藏
打赏
评论
kafka启动、kafka查看、创建topic的命令
这里目前只是记录了我使用过的操作，所以并不完整。一、kafka启动（linux环境）1、单节点启动（非集群）（1）下载kafka安装包http://kafka.apache.org/downloads，我这里下载的是kafka_2.11-2.3.0.tgz（2）解压（不需要安装，直接配置可用） tar -xzvfkafka_2.11-2.3.0.tgz（3）对于单节点kaf...
复制链接
扫一扫
专栏目录
kafka消息可视化查看工具
04-11
1.可用于查看kafka内的消息数据，消息的偏移量，消费分组数等信息。
2.主要用于开发调试，勿过于依赖辅助工具，命令使用才是根本。
kafka中topic的创建和查询
最新发布
jjt_zaj的博客
11-21
744
kafka topic
参与评论
您还未登录，请先
登录
后发表或查看评论
Kafka_命令经验集
初学者乐园的博客
11-24
359
1. 查看所有 topic 列表
./kafka-topics.sh --zookeeper {ip}:2181 --list
2. 创建 topic 主题
./kafka-topics.sh --create --zookeeper {ip}:2181 --replication-factor 1 --partitions 1 --topic {topic_name}
3. 创建生产者消息
./kafka-console-producer.sh --broker-list {ip}:9093 --topi
kafka对topic的一些命令
zll_1234的博客
08-22
146
1、查询kafka版本：
find / -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'
查询结果：
kafka_2.10-0.10.2-kafka-2.2.0.jar
2.10是scala的版本
0.10.2是Kafka的版本
2、进入Kafka安装目录，并进入bin目录：
cd /opt/cloudera/parcels/KAFKA/b...
如何在kafka中创建topic
qq_55961709的博客
09-05
3421
如何在kafka中创建topic
kafka 创建topic，查看topic
热门推荐
每天记录一点点，20181220回头看看是什么样
11-09
3万+
创建
创建kafka topic
bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181
方法一：
执行linux命令：
bin/kafka-topics.sh --create --topic topicna
Kafka创建&查看topic，生产&消费指定topic消息
勇往直前的专栏
09-23
2032
启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html）
1.创建Topic
　　1）运行命令：./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 ...
kafka创建删除查看topic的命令
ccsynl的博客
12-15
420
创建topic的命令（例：创建topic test）
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test
partitions是主题分区数，replication-factor是主题副本数量
删除topic的命令（例：删除topic test）
bin/kafka-topics.sh --delete --zookeeper localhost:2
kafka创建topic、添加配置等相关操作
weixin_47019045的博客
06-28
6163
创建topic、kafka命令行消费者、kafka命令行生产者、删除topic、kafka单个topic增加配置。
kafka-console-consumer、kafka-console-producer、kafka-topics、kafka-configs的使用
kafka topic常用命令
学亮编程手记
04-18
281
创建topic
[root@node01 bin]# ./kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --partitions 1 --topic first_topic
Created topic "first_topic".
[root@node01 bin]#
查看topic
[roo...
kafka创建topic命令_kafka常用命令总结
weixin_39692172的博客
12-03
5229
kafka服务启动$KAFKA_HOME/bin/kafka-server-start.sh-daemonconfig/server.properties创建Topic$KAFKA_HOME/bin/kafka-topics.sh --create --topic test0--zookeeper 127.0.0.1:2181 --config max.message.bytes=...
Windows Kafka创建&查看topic，生产&消费指定topic消息
anzhenxi3529的博客
01-06
1960
启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面文章）
1.创建Topic
　　1）运行命令：
kafka-topics.bat --create --zookeeper localhost:2181 --replication-fctor 1 --partition 1 --topic caijunjie
　　2181 是zookeeper 端...
KafkaTopicAPI
Loser_you的博客
05-27
39
创建topic
@Test
public void createTopic() {
Properties properties = new Properties();
properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-21:9092,kafka-22:9092");
AdminClient adminClient = KafkaAdminClient.create(properties);..
Kafka上对一个Topic增加partition
qq_39674417的博客
01-24
558
操作步骤如下：
通过kafka-topics.sh工具的alter命令，将topic_test的partitions从12增加到20；
./bin/kafka-topics.sh –zookeeper 192.168.2.225:2183/config/mobile/mq –alter –partitions 20 –topic topic_test
Kafka Shell基本命令（包括topic的增删改查）
wzf862187413的博客
04-12
226
Kafka Shell基本命令（包括topic的增删改查）
创建kafka topic
查看所有topic列表
查看指定topic信息
控制台向topic生产数据
控制台消费topic的数据
查看topic某分区偏移量最大（小）值
增加topic分区数
删除topic，慎用，只会删除zookeeper中的元数据，消息文件须手动删除
查看topic消费进度
创建kafka topi...
windows 环境下kafka 创建topic ，查看topic，删除 topic
weixin_44012027的博客
10-09
661
创建名称为test2的同topic
kafka-topics --create --bootstrap-server localhost:9092 --topic test3 --partitions 10 --replication-factor 1
查看topic
kafka-topics --list --bootstrap-server localhost:9092
删除名称为test3 的topic 命令如下
kafka-topics --create --bootstrap-server l
kafka创建topic_ELK|kafka增加及删除topic
weixin_39646405的博客
12-03
150
背景书接上回,想在kafka执行命令,其实是为删除一个无用的topic,但是在不知道正确删除姿势的情况下,只能先创建再删除,验证一下,也是去年的经验了,今年用的时候又翻半天,记录一下创建topic用的命令是kafka-topics.sh,我是在容器里运行的,应该是kafka命令都加到PATH路径了,可以任意位置执行查看所有topic列表kafka-topics.sh --zookeep...
【Kafka】命令行管理topic
Just Do IT
04-11
679
1. 创建topic
[hadoop@node03 bin]$ kafka-topics.sh --create --partitions 3 --replication-factor 2 --topic test --zookeeper node01:2181,node02:2181,node03:2181
Created topic "test".
参数说明：
partitions： 指定...
“相关推荐”对你有帮助么？
非常没帮助
没帮助
一般
有帮助
非常有帮助
提交
©️2022 CSDN
皮肤主题：编程工作室
设计师：CSDN官方博客
返回首页
yrc_Note
CSDN认证博客专家
CSDN认证企业博客
码龄7年
暂无认证
43
原创
25万+
周排名
80万+
总排名
17万+
访问
等级
1914
积分
20
粉丝
72
获赞
16
评论
217
收藏
私信
关注
热门文章
kafka启动、kafka查看、创建topic的命令
38730
vim模式下报错E37: No write since last change (add ! to override)
16586
vi vim如何显示行号
14328
Linux访问window下的磁盘分区出现“Error mounting /dev/sda5 at/media”错误的解决方法
9294
eclipse安装包下载
7584
分类专栏
maven
1篇
eclipse
linux命令
1篇
书籍
1篇
JavaScript
1篇
jstl
1篇
字符集
1篇
编码
1篇
C/C++
31篇
剑指offer
5篇
数据结构
5篇
java
24篇
linux
8篇
javaweb
11篇
jsp
8篇
C#
2篇
Qt编程
1篇
html
1篇
MFC
1篇
visual-studio
1篇
socket
1篇
设计模式
1篇
笔试题
2篇
Perl
1篇
kafka
1篇
最新评论
C#类型基础（值类型and引用类型）
yy为你疯狂:
老师写的很好,就是错别字实在太多,据我掐指一算,肯定用得是搜狗输入法,万恶的输入法啊,我本来就看不懂,用了这个输入法后,理解起作者的意思就更累了,男上加男啊。
使用循环的方式遍历二叉树
叶蓝枫起:
83行到86行不需要增加变量temp吧，可以继续用proot
交换机access与trunk口
杯水^瓢饮:
为什么我的PC1－PC3不能ping通呀
JAVA中关于实现Comparable接口问题，为什么对于使用Arrays排序的对象都要实现这个接口？
yrc_Note
回复
GeorgeLin98: 因为Person类并没有实现Comparable，虽然Person数组，存储了Student对象，但是传递给Test方法的参数是Person数组，编译器并不知道你数组实际存储的是Student对象。
JAVA中关于实现Comparable接口问题，为什么对于使用Arrays排序的对象都要实现这个接口？
GeorgeLin98:
一个Person类的数组，然后把Student实例填进去，只能调用Person类中有的方法，所以是不能排序的！
您愿意向朋友推荐“博客详情页”吗？
强烈不推荐
不推荐
一般般
推荐
强烈推荐
提交
最新文章
在eclipse中引入maven web项目，jar包没有发布到tomcat的lib目录下的解决办法
如何在Eclipse中创建maven的Java Web项目
关于字符串比较的方法进行建议
2020年3篇
2019年17篇
2018年4篇
2017年50篇
2016年4篇
目录
目录
分类专栏
maven
1篇
eclipse
linux命令
1篇
书籍
1篇
JavaScript
1篇
jstl
1篇
字符集
1篇
编码
1篇
C/C++
31篇
剑指offer
5篇
数据结构
5篇
java
24篇
linux
8篇
javaweb
11篇
jsp
8篇
C#
2篇
Qt编程
1篇
html
1篇
MFC
1篇
visual-studio
1篇
socket
1篇
设计模式
1篇
笔试题
2篇
Perl
1篇
kafka
1篇
目录
评论
被折叠的 条评论
为什么被折叠?
到【灌水乐园】发言
查看更多评论
打赏作者
yrc_Note
你的鼓励将是我创作的最大动力
¥2
¥4
¥6
¥10
¥20
输入1-500的整数
余额支付
(余额：-- )
扫码支付
扫码支付：¥2
获取中
扫码支付
您的余额不足，请更换扫码支付或充值
打赏作者
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额
抵扣说明：
1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。 2.余额无法直接购买下载，可以购买VIP、C币套餐、付费专栏及课程。
余额充值