Kafka学习笔记 --- 操作Topic

本文主要是介绍Kafka学习笔记 --- 操作Topic，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.添加和删除Topic
用户可以手动的添加Topic，或者首次将数据发布到不存在Topic时自动创建Topic。
如果自动创建Topic，需要了解一下相关的默认配置：

• 与Topic相关 的配置有服务器默认值和可选的按Topic覆盖，如果提供Topic的配置，则可以使用服务器的默认配置，在创建Topic的时候通过提供一个或者多个—config选项来设置代替值。本示例使用自定义的最大邮件大小和刷新率创建一个名字为my-topic的Topic：
   

>bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic my-topic --partitions 1 \     --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1

 

• 覆盖也可以在以后使用alert configs命令进行更改或者设置。本示例更新my-config的最大message大小：

> bin/kafka-configs.sh --zookeeper lo

这篇关于Kafka学习笔记 --- 操作Topic的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---