在Ubuntu 20.04环境下,Kafka的安装、部署及基础使用方法如下:

首先,我们需要安装Java环境,因为Kafka是基于Java开发的。打开终端,输入以下命令:

sudo apt update
sudo apt install default-jdk

安装完成后,可以通过 java -version命令查看Java版本,确保安装成功。

接下来,我们开始安装Kafka。首先,访问Apache Kafka的官方下载页面,找到最新的Kafka版本,复制下载链接。然后在终端中输入以下命令下载并解压Kafka:

wget http://www.apache.org/dyn/closer.cgi?path=/kafka/2.8.0/kafka_2.13-2.8.0.tgz
tar xzf kafka_2.13-2.8.0.tgz
mv kafka_2.13-2.8.0 /usr/local/kafka

这样,Kafka就被安装在了/usr/local/kafka目录下。

接下来,我们需要启动Kafka。Kafka的运行依赖于ZooKeeper,所以我们需要先启动ZooKeeper。在终端中输入以下命令:

/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties

ZooKeeper启动后,我们再启动Kafka。在新的终端窗口中输入以下命令:

/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties

至此,Kafka已经成功启动。

接下来,我们来看看如何使用Kafka。首先,我们创建一个名为"test"的主题。在终端中输入以下命令:

/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

然后,我们可以通过以下命令查看已创建的主题:

/usr/local/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181

接着,我们启动一个生产者,向"test"主题发送消息。在终端中输入以下命令:

/usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

然后,我们可以在命令行中输入消息,每输入一行消息,就按回车键发送。

最后,我们启动一个消费者,接收"test"主题的消息。在新的终端窗口中输入以下命令:

/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

这样,我们就可以在消费者的终端窗口中看到生产者发送的消息了。

以上就是在Ubuntu 20.04环境下,Kafka的安装、部署及基础使用方法。希望对你有所帮助。

云服务器推荐

蓝易云国内/海外高防云服务器推荐


海外免备案云服务器链接:www.tsyvps.com

蓝易云香港五网CN2 GIA/GT精品网络服务器。拒绝绕路,拒绝不稳定。


百度搜索:蓝易云

蓝易云是一家专注于香港及国内数据中心服务的提供商,提供高质量的服务器租用和云计算服务、包括免备案香港服务器、香港CN2、美国服务器、海外高防服务器、国内高防服务器、香港VPS等。致力于为用户提供稳定,快速的网络连接和优质的客户体验。
最后修改:2023 年 10 月 26 日
如果觉得我的文章对你有用,请随意赞赏