订阅kakka安装启动教程
来源：网络收集 点击： 时间：2024-06-04首先，官网下载https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka_2.12-2.2.0.tgz
2/9下载之后放到linux上解压：tar -zxvfkafka_2.12-2.2.0.tgz
3/9然后使用kafka自带的启动zookeeper启动,因为kafka依赖于zookeeper,所以要先启动zookeeper
4/9Ctrl+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即可，如果内存不够，那就需要扩容或者先关掉其他应用
5/9如果按上面的启动命令，是没有在后台启动的，我们可以用用nohup命令后台启动
6/9启动成功之后，创建主题：./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
提示创建成功
7/9接下来可以使用命令查看主题：./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
8/9可以使用命令发送消息：
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
，然后在出现的输入框中输入消息
9/9最后，我们在消费者中开始消费消息：./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
读出来的就是我们刚刚测试发送的4条消息
注意事项启动的时候要在后台启动，否则Ctrl+C之后就会关闭进程了
版权声明：
1、本文系转载，版权归原作者所有，旨在传递信息，不代表看本站的观点和立场。
2、本站仅提供信息发布平台，不承担相关法律责任。
3、若侵犯您的版权或隐私，请联系本站管理员删除。
4、文章链接：http://www.1haoku.cn/art_878512.html
