在 Debian 上“设置 Kafka 主题”通常分为两部分:安装/启动 Kafka 和 创建/配置主题。下面给你一个从零开始的简明流程(以 Kafka 3.x 为例,使用 KRaft 或 ZooKeeper 都可以,这里先给最常见的 ZooKeeper 方式)。
Kafka 需要 Java:
sudo apt update
sudo apt install -y openjdk-17-jdk
java -version
cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
(建议用 nohup 或 systemd 后台运行)
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh \
--create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 3 \
--replication-factor 1
说明:
--topic:主题名--partitions:分区数--replication-factor:副本数(单节点只能是 1)bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server localhost:9092
bin/kafka-topics.sh --delete --topic test-topic --bootstrap-server localhost:9092
(需 delete.topic.enable=true)
创建时指定参数:
bin/kafka-topics.sh --create \
--topic logs \
--bootstrap-server localhost:9092 \
--partitions 6 \
--replication-factor 1 \
--config retention.ms=604800000 \
--config cleanup.policy=delete
如果你想用 systemctl 管理 Kafka,我可以帮你写:
kafka.servicezookeeper.service如果你是指:
告诉我你的使用场景,我可以给你更合适的配置。