Kafka是由Apache软件基金会开发的一个开源事件流处理平台，它由数个Broker节点组成，支持发布-订阅消息服务。
一、安装Java开发环境
在安装Kafka之前，需要先安装Java开发环境，可以通过以下命令来检查是否已经安装了Java：
java -version
如果没有安装Java，可以使用以下命令在Ubuntu上安装：
sudo apt update
sudo apt install default-jre
sudo apt install default-jdk
在CentOS上安装Java：
sudo yum install java-1.8.0-openjdk
二、下载和安装Kafka
可以从Kafka的官网下载Kafka二进制文件并解压缩。
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.0/kafka_2.12-2.6.0.tgz
tar -xzf kafka_2.12-2.6.0.tgz
cd kafka_2.12-2.6.0
三、启动Kafka Broker
在启动Kafka之前，可以在config/server.properties文件中修改一些配置项，比如broker.id、listeners、log.dirs等等。
接下来，可以使用以下命令启动Kafka Broker：
bin/kafka-server-start.sh config/server.properties
在启动之后，可以使用以下命令来检查Kafka是否正常启动：
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果显示无误，说明Kafka已经正常启动。
四、创建和使用Topic
在Kafka中，可以使用以下命令来创建一个Topic：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
可以使用以下命令来查看已经创建的Topics：
bin/kafka-topics.sh --list --zookeeper localhost:2181
可以使用以下命令来往Topic中发送消息：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
可以使用以下命令来接收Topic中的消息：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
五、Kafka常用命令
- 创建Topic: bin/kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
- 查看Topic列表: bin/kafka-topics.sh –list –zookeeper localhost:2181
- 查看Topic详情: bin/kafka-topics.sh –describe –zookeeper localhost:2181 –topic test
- 往Topic中写入消息: bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test
- 从Topic中读取消息: bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from-beginning
- 删除Topic: bin/kafka-topics.sh –zookeeper localhost:2181 –delete –topic test
- 开启Kafka管理功能: bin/kafka-server-start.sh config/server.properties –override delete.topic.enable=true
原创文章，作者：NTCWQ，如若转载，请注明出处：https://www.506064.com/n/334939.html
微信扫一扫 
支付宝扫一扫 