启动kafka
bin/kafka-server-start.sh config/server.properties、
后台启动加参数-daemon
bin/kafka-server-start.sh -daemon ../config/server.properties
查看topic信息
cd到kafka的安装位置，找到bin目录 单机/集群都可以配置参数，下面命令为查询集群的topic信息
bin/kafka-topics.sh --zookeeper master:2181,slave1:2181,slave2:2181,slave3:2181,slave4:2181 --list
创建topic
cd到kafka的安装位置，找到bin目录 执行以下命令则可为本机创建一个名为test2的topic 且有一个副本一个partition
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
cd到bin目录下 执行以下命令则为集群创建一个名为test_topic的topic 且有四个副本四个partition
bin/kafka-topics.sh --zookeeper master:2181,slave1:2181,slave2:2181,slave3:2181,slave4:2181 --create --topic test_topic --replication-factor 4 --partitions 4
创建producer
以下俩行命令分别为一台服务器和多台集群服务器创建producer
bin/kafka-console-producer.sh --broker-list slave4:9092 --topic test_topic
bin/kafka-console-producer.sh --broker-list master:9092,slave1:9092,slave2:9092,slave3:9092,slave4:9092 --topic test_topic
创建consumer
以下俩行命令分别为多台集群服务器和一台服务器创建consumer 注意--from-beginning参数为从最开始位置开始消费，即历史数据也消费
bin/kafka-console-consumer.sh --bootstrap-server master:9092,slave1:9092,slave2:9092,slave3:9092,slave4:9092 --topic test_topic --group test_consumer_group --from-beginning
以上是一句完整的命令，切勿遗漏
bin/kafka-console-consumer.sh --bootstrap-server slave4:9092 --topic test_topic --from-beginning
列举消费者组
bin/kafka-consumer-groups.sh --bootstrap-server master:9092,slave1:9092,slave2:9092,slave3:9092,slave4:9092 --list
查看消费者组消费情况1-无活着的消费者，无延迟消费
bin/kafka-consumer-groups.sh --bootstrap-server master:9092,slave1:9092,slave2:9092,slave3:9092,slave4:9092 --group test_consumer_group --describe