在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版本与你安装的Java版本兼容。
# 启动Zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties & <h1>启动Kafka服务器</h1><p>bin/kafka-server-start.sh config/server.properties &
bin/kafka-topics.sh --create --topic my-new-topic --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1
确保你的Kafka服务器正在运行,并且localhost:9092是正确的bootstrap server地址。
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果my-new-topic出现在列表中,那么恭喜你,你已经在Debian系统上成功创建了一个Kafka主题!
请注意,这些步骤假设你已经正确配置了Kafka和Zookeeper,并且它们正在运行。如果遇到任何问题,请检查Kafka和Zookeeper的日志文件以获取更多信息。
以上就是Kafka主题在Debian上怎么创建的详细内容,更多请关注php中文网其它相关文章!
Kafka Eagle是一款结合了目前大数据Kafka监控工具的特点,重新研发的一块开源免费的Kafka集群优秀的监控工具。它可以非常方便的监控生产环境中的offset、lag变化、partition分布、owner等,有需要的小伙伴快来保存下载体验吧!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号