参考文档:
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