Kafka主题管理在Debian上如何操作

在Debian上管理Kafka主题需使用命令行工具，核心操作如下：

1. 安装依赖
   先安装Java运行环境（Kafka依赖Java）：

   sudo apt update  
   sudo apt install openjdk-11-jdk  # 推荐Java 11  
   

   验证安装：java -version。

2. 下载并启动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 &  
     

3. 主题管理命令

   操作	命令格式	示例
   创建主题	kafka-topics.sh --create --topic <主题名> --partitions <分区数> --replication-factor <副本数> --bootstrap-server <broker地址>	kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2 --bootstrap-server localhost:9092
   查看主题列表	kafka-topics.sh --list --bootstrap-server <broker地址>	kafka-topics.sh --list --bootstrap-server localhost:9092
   查看主题详情	kafka-topics.sh --describe --topic <主题名> --bootstrap-server <broker地址>	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 <broker地址>	kafka-topics.sh --delete --topic test --bootstrap-server localhost:9092

注意：

• 删除主题前需确保delete.topic.enable=true（默认开启）。
• 生产环境中建议通过配置文件管理参数，而非直接命令行修改。
• 可使用kafka-console-producer.sh和kafka-console-consumer.sh测试消息收发。