标签：-- zookeeper kafka topic sh 常用命令 172.21

启动kafka

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

停止kafka

sh kafka-server-stop.sh -daemon ../config/server.properties

启动zookeeper

sh zookeeper-server-start.sh  ../config/zookeeper.properties

停止zookeeper

sh zookeeper-server-stop.sh  ../config/zookeeper.properties

查看所有groupid

sh kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.51.109:9092 --list

查看指定groupid的详细信息

sh kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.51.109:9092 --group point_expire_group --describe

查看zookeeper上所有的topic

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

查看指定topic的信息

sh kafka-topics.sh --describe --zookeeper 172.21.51.109:2181 --topic point_expire_topic

创建topic(partitions为分区数量，replications-factor为副本数量，zookeeper为集群地址，多个可用，隔开)

sh kafka-topics.sh --create --topic point_expire_topic --partitions 2 --replication-factor 3 --zookeeper 172.21.51.108:2181,172.21.51.109:2181,172.21.51.110:2181

删除topic

sh kafka-topics.sh --delete --zookeeper 172.21.51.108:2181,172.21.51.109:2181,172.21.51.110:2181 --topic point_expire_topic

修改topic日志存储时间，无需重启

ms 时间单位为毫秒值

sh  kafka-topics.sh --topic point_expire_topic --zookeeper 172.21.51.108:2181,172.21.51.109:2181,172.21.51.110:2181 --alter --config retention.ms=86400000‬

标签：--,zookeeper,kafka,topic,sh,常用命令,172.21
来源： https://blog.csdn.net/weixin_51613454/article/details/123070048

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。