创建 topic

脚本手工创建

/opt/kafka/bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181  
  • –topic 指定 topic name
  • –partitions 指定分区数,这个参数需要根据 broker 数和数据量决定,正常情况下,每个 broker 上两个 partition 最好;
  • –replication-factor 指定 partition 的 replicas 数,建议设置为2;

程序自动创建:

开启自动创建配置:auto.create.topics.enable=true

使用程序直接往 kafka 中相应的 topic 发送数据,如果 topic 不存在就会按默认配置进行创建。

标签: none

添加新评论