bin/kafka-topics.sh --bootstrap-server broker_host:port
--create --topic my_topic_name \
--partitions 20 --replication-factor 3 --config x=y
bin/kafka-topics.sh --bootstrap-server broker_host:port
--alter --topic my_topic_name \
--partitions 40
增加配置:
bin/kafka-configs.sh --bootstrap-server broker_host:port
--entity-type topics --entity-name my_topic_name
--alter --add-config x=y
删除配置:
bin/kafka-configs.sh --bootstrap-server broker_host:port
--entity-type to