Kafka相关笔记

2023-02-21 字数：165 字阅读时长：约 0 分钟阅读次
常用命令
常用命令

# 创建topic
kafka-topics.bat --create --bootstrap-server ${kafka地址} --replication-factor 1 --partitions 1 --topic ${topicname}

example:kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic month_supno_cost_test

# 生产消息
kafka-console-producer.bat --broker-list ${kafka服务地址} --topic ${topicname}

example: kafka-console-producer.bat --broker-list localhost:9092 --topic month_supno_cost_test

# 查询所有topic
kafka-topics.bat --list --zookeeper ${zookeeper服务地址}

example: kafka-topics.bat --list --zookeeper localhost:2181

# 查询topic内容
kafka-console-consumer.bat --bootstrap-server ${kafka服务地址} --topic ${topicname} --from-beginning

example: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic order_temp_data_test --from-beginning

/opt/cloudera/parcels/CDH/bin/kafka-console-consumer  --bootstrap-server pro-data-sh003:9092 --topic dw_gps_pro --from-beginning >> dw_gps_pro.txt

# 查询偏移量
kafka-run-class kafka.tools.GetOffsetShell --broker-list ${kafka服务地址} --topic ${topicName}

kafka-run-class kafka.tools.GetOffsetShell --broker-list pro-data-sh003:9092 --topic temp_gps_out