kafka操作
Posted jiashengyang
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka操作相关的知识，希望对你有一定的参考价值。
kafka 操作：
source /etc/profile
查看消费：
/usr/local/platform/kafka_2.11-1.1.0/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic all.log_impbus_impressions_deferred_pricing.0.proto --from-beginning
添加生产：
/usr/local/platform/kafka_2.11-1.1.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic all.log_impbus_impressions_deferred_pricing.0.proto
查看偏移量：
/usr/local/platform/kafka_2.11-1.1.0/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic all.log_impbus_impressions_deferred_pricing.0.proto --time -2
查看topic
/usr/local/platform/kafka_2.11-1.1.0/bin/kafka-topics.sh --list --zookeeper localhost:2181
清除：./clean-all-logs.sh
查看端口：telnet localhost 9092
以上是关于kafka操作的主要内容，如果未能解决你的问题，请参考以下文章