参考文档：

https://blog.csdn.net/fengzheku/article/details/50585972

http://kafka.apache.org/documentation/

http://lxw1234.com/archives/2015/11/549.htm ************

https://blog.csdn.net/see_you_see_me/article/details/78468421  python操作kafka

需求，如果topic不存在，不允许自动创建

Topic参数

# 每个topic的分区个数，更

多的partition会产生更多的segment file
num.partitions=2
# 是否允许自动创建topic ，若是false，就需要通过命令创建topic
auto.create.topics.enable =true
# 一个topic ，默认分区的replication个数 ，不能大于集群中broker的个数。
default.replication.factor =1
# 消息体的最大大小，单位是字节
message.max.bytes = 1000000

禁止删除topic

delete.topic.enable=false

版权声明：本文为huochaihe原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/huochaihe/p/9254384.html