启动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 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
