大数据-Kafka-常用命令

启动服务

• 前台启动

bin/kafka-server-start.sh config/server.properties

• 后台启动

bin/kafka-server-start.sh -daemon config/server.properties

停止服务

bin/kafka-server-stop.sh

创建Topic

bin/kafka-topics.sh --zookeeper localhost:2181 --create --partitions 2 --replication-factor 3 --topic test-topic

查看所有Topic

bin/kafka-topics.sh --zookeeper localhots:2181 --list

查看所有Topic详细信息

    `bin/kafka-topics.sh --zookeeper localhost:2181 --describe`

查看指定主题的详细信息

    `bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test-topic`

删除Topic

bin/kafka-topics.sh --zookeeper localhost:2181 --delete  --topic test-topic

修改日志保存时间

./kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name topicname --alter --add-config log.retention.hours=120

 ./kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name topicname --alter --add-config retention.ms=259200000