1.kafka-topics 主题
如：kafka-topics --create --zookeeper 10.0.4.142:2181/kafka --replication-factor 1 --partitions 1 --topic test ---创建一个主题
#查看kafka主题帮助命令
kafka-topics --help
--alter 改变分区的数量、副本分配、/、主题的配置
--config <String: name=value> 重写配置
配置：
cleanup.policy
compression.type
delete.retention.ms
file.delete.delay.ms
flush.messages
flush.ms
follower.replication.throttled.
副本：
index.interval.bytes
leader.replication.throttled.replicas
max.message.bytes
message.format.version
message.timestamp.difference.max.ms
message.timestamp.type
min.cleanable.dirty.ratio
min.compaction.lag.ms
min.insync.replicas
预分配：
retention.bytes
retention.ms
segment.bytes
segment.index.bytes
segment.jitter.ms
segment.ms
--create 创建一个主题
--delete 删除一个主题
--delete-config <String: name> 删除配置
--describe 查看主题描述
--disable-rack-aware 禁用机架感知副本分配
--force 禁用控制台提示
--help 查看帮助选项
--if-exists 如存在则执行对应的操作
--if-not-exists 如不存在则创建主题
--list 查看主题列表
--partitions <Integer: # of partitions> 主题的分区数量
--replica-assignment <String:
broker_id_for_part1_replica1 :
broker_id_for_part1_replica2 ,
broker_id_for_part2_replica1 :
broker_id_for_part2_replica2 , ...> 服务代理broker列表
--replication-factor <Integer: replication factor> 副本因子
--topic <String: topic> 设置主题名
--topics-with-overrides 重写主题名
--unavailable-partitions 不可达的分区
--under-replicated-partitions 显示在副本分区下
--zookeeper <String: urls> zookeeper所在服务器如10.2.1.169:2181/kafka