kafka常用命令

启动kafka

kafka-server-start.sh $KAFKA_HOME/config/server.properties
kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties
首次启动成功后，会在$KAFKA_HOME/logs目录下创建相应的日志文件

获取Kafka进程的PID
PIDS=$(jps | grep -i 'Kafka' | awk '{print $1}') 查看Kafka进程PID echo \$ PIDS
杀掉Kafka进程
kill -9 $PIDS

执行jps命令查看Java进程，此时进程信息至少包括以下几项：

Jps
QuorumPeerMain
Kafka

查看topic

kafka-topics.sh --list --zookeeper localhost:2181

创建topic

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicname

启动生产者

kafka-console-producer.sh --broker-list localhost:9092 --topic topicname

启动消费者

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

删除topic

kafka-topics.sh --delete --zookeeper localhost:2181 --topic topicname
如果topic被正常删除，查询不到，说明topic没有被引用；如果被标记为--marked for deletion，说明还有对这个topic的引用

查看数据过期时间

kafka-configs.sh --zookeeper localhost:2181 --describe --entity-name my_first_topic --entity-type topics

修改数据过期时间

kafka-configs.sh --zookeeper localhost:2181 --alter --entity-name my_first_topic --entity-type topics --add-config retention.ms=86400000

查看主题数据偏移量

kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic task_instance_info --time -1