kafka操作中

kafkaのいくつかの操作コマンド:
すべてのtopicの情報を表示

./kafka-topics.sh --zookeeper 127.0.0.1/kafka --describe

topicの情報を表示

 ./kafka-topics.sh --zookeeper 127.0.0.1/kafka --describe --topic mine-topic

topicの作成指定バックアップは3、パーティション数は6、topic-level構成retentionです.ms

./kafka-topics.sh --zookeeper 127.0.0.1/kafka --create --partitions 6 --replication-factor 3 --topic mine-topic --config retention.ms=8640000

topic_を削除レベル構成

./kafka-topics.sh --zookeeper 127.0.0.1/kafka --alter --topic mine-topic --deleteConfig retention.ms

パーティションの変更(注意:topicは現在サポートされていません.パーティションの数を減らしたり、バックアップの数を変更したりします)

./kafka-topics.sh --zookeeper 127.0.0.1/kafka --alter --partitions 36 --topic mine-topic

zkConnector消費によりコマンドで消費量、topic最新offsetおよび蓄積量を得ることができます

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker -zkconnect 127.0.0.1/kafka -topic mine-topic -group groupname

コマンドは、あるtopicを削除します(この削除後、バックグラウンドではkafkaデータファイルのcheckpointの2つのファイルの対応する情報を手動で削除し、zk上のconfig/topicsの情報を削除し、brokerを再起動し、慎重に削除する必要があります)、kafkaのあるtopicのデータを削除すると、このtopicのtopic_レベルの失効時間は、小データの削除を変更してから大きくすればよい.

./kafka-run-class.sh kafka.admin.DeleteTopicCommand --zookeeper 127.0.0.1/kafka --topic mine-topic

0.8.1バージョンの後にdelete topicメソッドが提供されました(公式の説明では問題が反映されます)

./kafka-topics.sh --zookeeper zk_host:port/chroot --delete --topic my_topic_name