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