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基本操作该怎么执行有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注编程之家行业资讯频道，感谢大家的支持。