kafka命令

connect-distributed.sh

connect-mirror-maker.sh

connect-standalone.sh

kafka-acls.sh

kafka-broker-api-versions.sh

kafka-configs.sh

kafka-console-consumer.sh

从quickstart-events topic中消费消息

kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

kafka-console-producer.sh

生产者给quickstart-events topic中写入消息

 bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

kafka-consumer-groups.sh

kafka-consumer-perf-test.sh

kafka-delegation-tokens.sh

kafka-delete-records.sh

kafka-dump-log.sh

kafka-leader-election.sh

kafka-log-dirs.sh

kafka-mirror-maker.sh

kafka-preferred-replica-election.sh

kafka-producer-perf-test.sh

kafka-reassign-partitions.sh

kafka-replica-verification.sh

kafka-run-class.sh

kafka-server-start.sh

启动kafka代理服务

# 启动kafka代理服务
$ bin/kafka-server-start.sh config/server.properties

kafka-server-stop.sh

关闭kafka代理服务

# 关闭kafka代理服务
$ bin/kafka-server-start.sh config/server.properties

kafka-streams-application-reset.sh

kafka-topics.sh

在编写第一个事件之前，必须创建一个主题

创建topic

--create 创建
--topic quickstart-events 主题quickstart-events
--bootstrap-server kafka服务

# 创建名称为quickstart-events的主题
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

查询所有topic

bin/kafka-topics.sh --describe --bootstrap-server localhost:9092

image.png

Topic: __consumer_offsets 为默认topic

查询某个topic

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

kafka-verifiable-consumer.sh

kafka-verifiable-producer.sh

trogdor.sh

zookeeper-security-migration.sh

zookeeper-server-start.sh

启动zookeeper服务

# 启动zookeeper服务
# Note: Soon, ZooKeeper will no longer be required by Apache Kafka.
$ bin/zookeeper-server-start.sh config/zookeeper.properties

zookeeper-server-stop.sh

关闭zookeeper服务

# 关闭zookeeper服务
$ bin/zookeeper-server-start.sh config/zookeeper.properties

zookeeper-shell.sh