如何在Kafka上创建一个Topic【分享】

如何在Kafka上创建一个Topic【分享】

脚本手工创建

./bin/kafka-topics.sh –zookeeper 192.168.2.225:2183/config/mobile/mq –create –topic test.example –replication-factor 2 –partitions 24
–topic指定topic name
–partitions指定分区数，这个参数需要根据broker数和数据量决定，正常情况下，每个broker上两个partition最好；
–replication-factor指定partition的replicas数，建议设置为2；

程序自动创建：

开启自动创建配置：auto.create.topics.enable=true
使用程序直接往kafka中相应的topic发送数据，如果topic不存在就会按默认配置进行创建。

[mw_shl_code=bash,true]auto.create.topics.enable=true [/mw_shl_code]

在那个配置文件里面？

Nicholas 发表于 2015-10-9 16:33
在那个配置文件里面？

配置文件在config/server.properties