首页 > 行业资讯 > 资讯动态

kafka 常用命令

日期：2024-07-17 　作者：小天　来源：www.txunda.com 　人气：486

1 集群操作
        1.1 启动集群,在每个设备启动Zookeeper：bin/zookeeper-server-start.sh config/zookeeper.properties,若不想显示日志信息：bin/zookeeper-server-start.sh config/zookeeper.properties > /dev/null 2>&1 &,在每个设备启动Kafka服务器：bin/kafka-server-start.sh config/server.properties,若不想显示日志信息：bin/kafka-server-start.sh config/server.properties > /dev/null 2>&1 &
        1.2 关闭集群,在每个设备关闭Kafka服务器：垃圾桶/kafka-server-stop.sh,在每个设备关闭Zookeeper：垃圾箱/zookeeper-server-stop.sh
        1.3 检查Kafka状态,查看Kafka服务的状态可以使用 kafka-broker-api-versions.sh：bin/kafka-broker-api-versions.sh --bootstrap-server 本地主机：9092
        1.4 重新分配分区,重新分配分区通常用于扩展Kafka集群时，将主题的分区重新分配到新的broker上。使用以下步骤进行分区重新分配：生成重新分配方案：bin/kafka-reassign-partitions.sh --generate --zookeeper localhost：2181 --topics-to-move-json-file topics-to-move.json --broker-list “0,1,2”执行重新分配：bin/kafka-reassign-partitions.sh --execute --zookeeper localhost：2181 --reassignment-json-file reassignment.json,查看重新分配状态：bin/kafka-reassign-partitions.sh --verify --zookeeper localhost：2181 --reassignment-json-file reassignment.json

天津天迅达科技有限公司
如果您需要相关服务，可以找天津天迅达科技有限公司，我们的业务有Web开发、iOS APP、Android APP、微信开发、HTML5开发等，天迅达——您身边的App个性化定制专家！
        1.5 查看ZooKeeper中的Kafka数据,你可以使用ZooKeeper的命令行客户端 zkCli.sh 来查看Kafka在ZooKeeper中的数据：bin/zookeeper-shell.sh localhost：2181,进入ZooKeeper shell后，可以使用以下命令：查看根节点：ls /,查看Kafka的brokers信息：ls /brokers/ids
2 主题操作
        2.1 相关参数
        --topic：指定主题的名称。
        --bootstrap-server：Kafka broker的地址。
        --replication-factor：副本因子，即每个主题分区的副本数。
        --partitions：分区数。
        2.2 创建主题
        创建主题test-topic：bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost：9092 --replication-factor 3 --partitions 2
        2.3 查看主题
        列出所有主题：bin/kafka-topics.sh --list --bootstrap-server localhost：9092,描述主题test-topic的详细信息：bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server localhost：9092
        2.4 删除主题
        删除主题test-topic：bin/kafka-topics.sh --delete --topic test-topic --bootstrap-server localhost：9092
        2.5 修改主题
        修改主题test-topic：bin/kafka-topics.sh --alter --topic test-topic --bootstrap-server your-kafka-bootstrap-server：9092 --config max.message.bytes=10485760
以上所有设计图和部分文字均来自网络，如有侵权，请call我删除，感谢~
天津天迅达科技有限公司经过多年来对APP、小程序、以及网站建设的探索，已经帮助每一个客户快速开发出属于自己的APP、小程序、网站，是万千企业之选。
标签：天迅达科技天津APP开发天津网站建设网站建设