Kafka主题管理在Debian上如何操作
在Debian上管理Kafka主题需使用命令行工具,核心操作如下:
-
安装依赖
先安装Java运行环境(Kafka依赖Java):sudo apt update sudo apt install openjdk-11-jdk # 推荐Java 11
验证安装:
java -version
。 -
下载并启动Kafka
- 下载Kafka:
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.13-3.5.2.tgz tar -xzf kafka_2.13-3.5.2.tgz cd kafka_2.13-3.5.2
- 启动Zookeeper(Kafka依赖Zookeeper):
bin/zookeeper-server-start.sh config/zookeeper.properties &
- 启动Kafka服务:
bin/kafka-server-start.sh config/server.properties &
- 下载Kafka:
-
主题管理命令
操作 命令格式 示例 创建主题 kafka-topics.sh --create --topic <主题名> --partitions <分区数> --replication-factor <副本数> --bootstrap-server
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2 --bootstrap-server localhost:9092
查看主题列表 kafka-topics.sh --list --bootstrap-server
kafka-topics.sh --list --bootstrap-server localhost:9092
查看主题详情 kafka-topics.sh --describe --topic <主题名> --bootstrap-server
kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092
修改主题配置 kafka-configs.sh --alter --entity-type topics --entity-name <主题名> --add-config <配置项>
kafka-configs.sh --alter --entity-type topics --entity-name test --add-config retention.ms=86400000
删除主题 kafka-topics.sh --delete --topic <主题名> --bootstrap-server
kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092
注意:
- 删除主题前需确保
delete.topic.enable=true
(默认开启)。 - 生产环境中建议通过配置文件管理参数,而非直接命令行修改。
- 可使用
kafka-console-producer.sh
和kafka-console-consumer.sh
测试消息收发。
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权请联系我们,一经查实立即删除!