在Ubuntu上设置Kafka主题分区可以通过以下步骤完成:
wget https://downloads.apache.org/kafka/2.8.1/kafka_2.13-2.8.1.tgz
tar -xzf kafka_2.13-2.8.1.tgz
sudo mv kafka_2.13-2.8.1 /opt/kafka
wget https://downloads.apache.org/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
tar -xzf apache-zookeeper-3.7.0-bin.tar.gz
sudo mv apache-zookeeper-3.7.0 /opt/zookeeper
编辑~/.profile
或/etc/profile
文件,添加以下内容:
export KAFKA_HOME=/opt/kafka
export PATH=$PATH:$KAFKA_HOME/bin
export ZK_HOME=/opt/zookeeper
export PATH=$PATH:$ZK_HOME/bin
然后执行:
source ~/.profile
server.properties
文件:进入Kafka安装目录的config
文件夹,编辑server.properties
文件:
broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/opt/kafka/logs
zookeeper.connect=localhost:2181
在Zookeeper安装目录的bin
文件夹下执行:
./zkServer.sh start
在Kafka安装目录的bin
文件夹下执行:
./kafka-server-start.sh config/server.properties
使用kafka-topics.sh
脚本创建主题。例如,创建一个名为my-topic
的主题,分区数为3,副本数为2:
./kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 2 --partitions 3 --topic my-topic
创建主题后,可以使用以下命令查看主题的分区信息和副本分配情况:
./kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic my-topic
以上步骤展示了如何在Ubuntu系统上安装和配置Kafka,并创建一个具有特定分区数和副本数的主题。请根据实际需求和集群规模调整分区数和副本数,以确保系统的性能和可靠性。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:apache kafka主题分区怎么设