手抄报 安全手抄报 手抄报内容 手抄报图片 英语手抄报 清明节手抄报 节约用水手抄报

kakka安装启动教程

时间:2024-10-13 22:34:49

1、首先,官网下载https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka_2.12-2.2.0.tgz

kakka安装启动教程

2、下载之后放到linux上解压:tar -zxvfkafka_2.12-2.2.0.tgz

kakka安装启动教程

3、然后使用kafka自带的启动zookeeper启动,因为kafka依赖于zookeeper,所以要先启动zookeeper

kakka安装启动教程

4、Ctrl+c后再去启动kafka,但是这稍僚敉视个时候会报错:Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error='Cannot allocate memory' (errno=12),字面上很容易理解是内存不足,先用free查看一下内存,如果内存是够的,那么修改config下面的server.properties中的一句话:export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"即可,如果内存不够,那就需要扩容或者先关掉其他应用

kakka安装启动教程

5、如果按上面的启动命令,是没有在后台启动的,我们可以用用nohup命令后台启动

kakka安装启动教程

6、启动成功之后,创建主题:./kafka-topics.sh --create --zookeeper loc锾攒揉敫alhost:2181 --replication-factor 1 --partitions 1 --topic test提示创建成功

kakka安装启动教程

7、接下来可以使用命令查看主题:./bin/kafka-topics.sh --list --bootstrap-server localhost:9092

kakka安装启动教程

8、可以使用命令发送消息:./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test,然后在出现的输入框中输入消息

kakka安装启动教程

9、最后,我们在消费者中开始消费消息:./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning读出来的就是我们刚刚测试发送的4条消息

kakka安装启动教程
© 手抄报圈