大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
今天就跟大家聊聊有关Kafka基本操作该怎么执行,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、微信小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了翔安免费建站欢迎大家使用!
当kafka数据进行持久化的时,为了区分不同的业务主题,设计了主题这个概念,类似数据库会有数据库名,数据库有若干数据表。不同类型消息数据按一定的规则进行分类,最后相同类型业务数据存储到同一个主题下。
通过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
$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基本操作该怎么执行有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。