前置条件
必须安装zookeeper.Linux安装饲养员
卡夫卡官方源
卡夫卡官网下载页面
下载卡夫卡安装包
<代码> #版本:kafka_2.11-2.3.0.tgz wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz
解压安装包
<代码>焦油-zxvf kafka_2.11-2.3.0.tgz cp kafka_2.11-2.3.0/usr/local/kafka
启动卡夫卡服务
<代码> cd/usr/local/kafka/bin #启动命令:守护进程进行启动/kafka-server-start。sh守护进程. ./配置/服务器。属性
备注:这里有可能报的错,因为默认情况下,卡夫卡默认的内存要1 g,如果你这里没有这么多内存可用,那么就会启动失败。报错如下:
<代码> Java Hotspot VM (TM) 64位服务器警告:信息:操作系统:commit_memory (0 x00000000c5330000, 986513408, 0)失败;错误='无法分配内存(errno=12) # #没有足够内存的Java运行时环境继续。 #本机内存分配(malloc)未能为承诺保留内存分配986513408字节。 #一个错误报告文件,保存更多的信息为: # hs_err_pid5535.log
<强> 解决方案 :
<代码>修改启动脚本:kafka-server-start.sh vim kafka-server-start.sh
设置内容根据自己情况进行设置。
创建一个主题/h4>
<代码> #名为测试的图,只有一个副本,一个分区
kafka-topics。sh——创建管理员localhost: 2181 - replication因子设置分区1——1——主题图
#查看卡夫卡的话题
kafka-topics。sh附些饲养员localhost: 2181
生产,消费测试
<代码> #启动生产端/kafka-console-producer。sh——券商名单上localhost: 9092——主题图 #启动消费端/kafka-console-consumer。sh - bootstrap-server localhost: 9092——主题图从头
