在Debian系统上创建Kafka主题,你需要遵循以下步骤:
sudo apt update
sudo apt install openjdk-11-jdk
wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0
请注意,你需要根据最新的Kafka版本替换下载链接中的版本号。
# 启动Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties &
# 启动Kafka服务器
bin/kafka-server-start.sh config/server.properties &
kafka-topics.sh
脚本来创建一个新的主题。以下是创建一个名为my-topic
的主题的命令,其中num-partitions
是分区数,replication-factor
是副本因子。bin/kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1
这里的localhost:9092
是Kafka服务器的地址和端口,如果你的Kafka服务器运行在不同的主机或端口上,请相应地修改这个参数。
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果一切顺利,你应该能在列表中看到你刚刚创建的主题。
请记住,这些步骤假设你已经正确配置了Kafka和Zookeeper。如果你遇到任何问题,检查config
目录下的配置文件,确保它们符合你的环境需求。