在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精品网络服务器。拒绝绕路,拒绝不稳定。