Kafka常用命令

# 启动Zookeeper
bin/zkServer.sh start

# 启动Kafka
nohup bin/kafka-server-start.sh config/server.properties &

# Kafka3以下
# 必须是--Zookeeper, --broker-list 或者 --bootstrap-server是不行的
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

# 查看创建的Topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

#
# 需要根据情况修改localhost为同一主机的IP,不然可能连不上
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

#需要根据情况修改localhost为同一主机的IP,不然可能连不上
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

# 启动消息者并打印Key
bin/kafka-console-consumer.sh --bootstrap-server=127.0.0.1:9092 --topic weidong-meta-area --property print.key=true

# 启动消息都并打印Key并指定key,Value的类型
bin/kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092 \
--property print.key=true \
--property key.separator=" : " \
--key-deserializer "org.apache.kafka.common.serialization.StringDeserializer" \
--value-deserializer "org.apache.kafka.common.serialization.StringDeserializer"

cat 文件 | kafka-console-producer.sh  --broker-list node1:9092 --sync --topic sky