文档章节

kafka学习(2)主题 Topic

太猪-YJ
 太猪-YJ
发布于 04/15 23:47
字数 684
阅读 4
收藏 0

Topic主题:

消息在进入kafka集群时,是以主题进行 数据归纳,既一条消息必须属于一个主题。

在kafka集群中可以有无数个主题。

从生产者的角度来说,他所操作的单位,一般情况下是以主题为单位。从消费者的角度来说,他所操作的单位,也是以主题为单位。

但是,生产者,消费者可以以比主题更精细的单位来操作----》分区,也就是消息的分类。

kafka始终支持多用户写入消息,订阅消息的。生产者和消费者,必须要知道操作的主题。

创建属于自己的主题:

常用命令:

启动kafka

Java\kafka_2.11-0.10.0.0>.\bin\windows\kafka-server-start.bat .\config\server.properties

 

windows 下查看主题 
D:\Java\kafka_2.11-0.10.0.0\bin\windows>kafka-topics.bat --describe --zookeeper localhost:2181 --topic     business_log(主题的名字)

 

查看主题的content
D:\Java\kafka_2.11-0.10.0.0\bin\windows>kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic business_log(主题的名字)

 

往主题写入消息
kafka-console-producer.bat --broker-list localhost:9092 --topic business_log

创建一个主题:

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic business_log(主题的名字)

在创建主题时,可以设置很多属性参数,需要哪些参数,可以查找参数设置表

查看所有创建的主题列表:

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
 

彻底删除本机kafka的topic

   1.server.properties 中添加delete.topic.enable=true

   2.执行D:\Developer\kafka_2.10-0.10.0.0\bin\windows>kafka-topics.bat --zookeeper 127.0.0.1(本机的IP):2181 --delete --topic business_log(主题的名字)

  3. 执行zookeeper-server-stop.bat,重启kafka

若是重新发送消息,会自动根据配置的partitions重建。

注意:不执行1步骤,就是假删除

一个broker服务下,是否可以创建多个主题?

可以

一个broker服务下,在创建主题时是否可以创建多个副本因子?

不可以,创建主题时的副本因子,应该小于等于可用的broker服务数。

 

 

查看主题和分区信息:

在kafka中,每个分区有一个编号,这个编号从0开始,

Leader:表示broker.id=0(server.properties文件中)如果有多个broker,那么broker.id的值肯定不相同,因为在kafka中如果有多个副本的话,就会存在leader与follower的关系。表示当前这个复本为leader所在的broker是哪一个。

Replicas:所有的复本列表, 0,1,2

Isr:可用列表数,0,1,2

只看主题。

 

© 著作权归作者所有

太猪-YJ
粉丝 10
博文 86
码字总数 81134
作品 0
海淀
私信 提问
kafka学习(6)集群的搭建

回顾: KAFKA集群搭建: 参考百度文章,搭建KAFKA本地集群。 这里要注意一个坑: kafka的config/server.properties文件中的broker.id要和kafka-logs/meta.properties里面的broker.id一致,而k...

太猪-YJ
04/15
0
0
kafka学习(一) ---- 基本概念以及环境搭建

由于项目涉及到kafka,自己以前没有接触过这方面的,学习了下,将搭建kafka运行环境同大家分享(单机搭建的Windows下的运行环境,Linux下的由于懒得装虚拟机就没有搭建,以后有时间在分享一次...

火龙战士
2016/08/11
1K
2
windows下安装kafka、zookeeper

前言 安装kafka之前必须安装jdk与zookeeper。 我安装的是jdk8,安装步骤这里省略。 1.安装zookeeper 1.到这个地址下载稳定版本的zookeeper版本,http://mirrors.shu.edu.cn/apache/zookeepe...

求是科技
01/17
0
0
创建topic验证kafka集群

0)'''kafka&zookpeer信息''' zkinfo: 172.18.238.2:2181 172.18.238.3:2181 172.18.238.4:2181 kafkainfo: 172.18.238.2:9092 172.18.238.3:9092 172.18.238.4:9092 1)'''创建Topic(包含10个......

SA_小科
2017/09/01
0
0
docker入门到实战(6)在docker中安装和使用kafka

下载镜像 这里使用了wurstmeister/kafka和wurstmeister/zookeeper这两个版本的镜像,在hub.docker.com中可以搜索到。 1、docker pull wurstmeister/zookeeper 2、docker pull wurstmeister/...

编程老司机
2018/05/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

北斗三号IGSO-2卫星发射成功!

6月25日,中国航天科技集团官方公众号宣布,北斗三号IGSO-2卫星发射成功! 航天科技集团表示,6月25日2点09分,我国在西昌卫星发射中心用长征三号乙运载火箭成功将北斗三号第2颗倾斜地球同步...

linuxCool
5分钟前
0
0
阿里java开发规约的Idea插件安装(英文)

Idea Plugin Prepare Project JDK: 1.7+ Gradle: 3.0+(Require JDK1.8+ for gradle) Build cd p3c-ideagradle clean buildPlugin Run plugin cd p3c-ideagradle runIde# run speci......

Airship
14分钟前
0
0
很多人转行做程序员选择web前端学习,前端简单在哪里?

不管你是工人阶层还是服务行业,是否想过转行IT,转行IT后肯定会选择一门编程语言进行深入学习,很多转行的人基础都不是太好,不是科班出身,甚至有的是专科乃至中专,前端的HTML和CSS相对其...

智云编程
27分钟前
0
0
一文读懂内网、公网和NAT

我们做弱电监控系统的时候,都避免不了要跟IP地址打交道,比如摄像头、NVR、服务器等这些设备安装好之后,就需要给它们配上IP,那这个IP地址你了解嘛?今天我们就一起来聊聊什么是内网、公网和...

老孟的Linux私房菜
32分钟前
3
0
聊聊dubbo的ExecuteLimitFilter

序 本文主要研究一下dubbo的ExecuteLimitFilter ExecuteLimitFilter dubbo-2.7.2/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/ExecuteLimitFilter.java public clas......

go4it
41分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部