要在Ubuntu上启动Kafka,您需要遵循以下步骤:
安装Java(如果尚未安装): Kafka需要Java运行环境。您可以使用以下命令安装OpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk
下载并解压Kafka: 访问Kafka官方网站(https://kafka.apache.org/downloads)下载最新版本的Kafka。然后使用以下命令解压:
tar -xzf kafka_2.13-<version>.tgz
cd kafka_2.13-<version>
将<version>替换为您下载的Kafka版本。
启动Zookeeper: Kafka依赖于Zookeeper,因此首先需要启动Zookeeper。在Kafka目录中运行以下命令:
bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka服务器: 在另一个终端窗口中,保持在Kafka目录下,运行以下命令启动Kafka服务器:
bin/kafka-server-start.sh config/server.properties
现在,Kafka已经在您的Ubuntu系统上运行了。您可以使用以下命令创建一个主题:
bin/kafka-topics.sh --create --topic <topic_name> --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
将<topic_name>替换为您想要创建的主题名称。
要查看所有主题,请运行:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
要从主题中生产消息,请运行:
bin/kafka-console-producer.sh --topic <topic_name> --bootstrap-server localhost:9092
要从主题中消费消息,请运行:
bin/kafka-console-consumer.sh --topic <topic_name> --from-beginning --bootstrap-server localhost:9092
请注意,这些命令中的<topic_name>应替换为您创建的主题名称。