大橙子网站建设,新征程启航

为企业提供网站建设、域名注册、服务器等服务

Kafka基本操作该怎么执行

今天就跟大家聊聊有关Kafka基本操作该怎么执行,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。

网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、微信小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了翔安免费建站欢迎大家使用!

Topic 主题

当kafka数据进行持久化的时,为了区分不同的业务主题,设计了主题这个概念,类似数据库会有数据库名,数据库有若干数据表。不同类型消息数据按一定的规则进行分类,最后相同类型业务数据存储到同一个主题下。

创建topic

自动创建

通过auto.create.topocs.enable属性来自动创建主题,默认该值是true。当生产者项kafk发送一个不存在的主题的时候,kafka会创建一个默认配置系数的主题。其中默认分区的数值由num.partitions控制,默认副本系数由default.replication.factor控制。具体配置文件在当前kafka的config/server.properties

手动创建

具体命令如下,主题名是topic-test,由于是开发环境搭建 分区和副本分区都是1

$ kafka-topics.sh --zookeeper localhost: 2181/kafka --create --topic topic-test --replication-factor 1 --partitions 1Created topic "topic-test".

--topic 定义topic名

--replication-factor  定义副本数

--partitions  定义分区数

查看topic

查看所有的topic

 $kafka-topics.sh --list -zookeeper localhost:2181__consumer_offsetstopic-test

查看topic 详情

$ kafka-topics.sh --zookeeper localhost:2181 --describe --topic topic-testTopic:test  PartitionCount:1  ReplicationFactor:1 Configs:  Topic: test Partition: 0  Leader: 0 Replicas: 0 Isr: 0

发送/接收消息

$ kafka-console-producer.sh --broker-list localhost:9092 --topic topic-test>hello kafka>hello world
kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic topic-testhello world

看完上述内容,你们对Kafka基本操作该怎么执行有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。


网页题目:Kafka基本操作该怎么执行
文章URL:http://dzwzjz.com/article/jeeogh.html
在线咨询
服务热线
服务热线:028-86922220
TOP