Kafka常用指令集合

1、建立一個topic

kafka-topics –create –zookeeper 195.1.10.157:2181/kafka –topic DW_LITE_STD –partitions 3 –replication-factor 3

說明：partitions指topic分區數，replication-factor指topic每個分區的副本數，其值不能大于broker個數，否則會報錯。

2、已建立topic增加分區

kafka-topics –alter –topics DW_LITE_STD –partitions 5 –zookeeper 195.1.10.157:2181/kafka_data

說明：partition隻能增加，不能減少。如果原有分散政策是hash的方式，将會受影響

3、删除topic

kafka-topics –delete –zookeeper 195.1.10.157:2181/kafka_data –topic DW_LITE_STD

4、檢視已建立的topic

kafka-topics –list –zookeeper 195.1.10.157:2181/kafka_data

kafka-topics –zookeeper 195.1.10.157:2181/kafka_data –describe |grep Isr

5、檢視指定topic的資訊

Kafka-topics –zookeeper 195.1.10.157:2181/kafka_data –describe –topic DW_LITE_STD

6、檢視topic最新（最舊偏移量）

*Kafka-run-class kafka.tools.GetOffsetShell –broker-list 195.1.10.159:29092 –topic DW_LITE_STD –time -1（-2）

說明：注：time為-1表示最大值，time為-2表示最小值

7、消費者指令

Kafka-console-consumer –zookeeper 195.1.10.157:2181/kafka_data –topic DW_LITE_STD –from-beginning

說明： –from-beginning 從頭開始讀取

8、生産者指令

Kafka-console-producer –zookeeper 195.1.10.157:2181/kafka_data –topic DW_LITE_STD

9、下線broker

Kafka-run-class kafka.admin.ShutdownBroker –zookeeper 195.1.10.157:2181 –broker #brokerId# –num.retries 3 –retry.int shutdown broker