kafka环境搭建

相关内容：

1、下载kafka安装包

http://kafka.apache.org/downloads

2、解压

tar -zxvf kafka_2.12-2.5.0.tgz -C /home/share/kafka
cd /home/share/kafka/kafka_2.12-2.5.0

3、开启kafka服务

启动zookeeper
    bin/zookeeper-server-start.sh config/zookeeper.properties

启动Kafka服务端
    bin/kafka-server-start.sh config/server.properties

4、创建topic

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看创建的主题
bin/kafka-topics.sh --list --zookeeper localhost:2181

5、发送消息

producer生产数据   
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>

consumer来接收数据
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

6、停止

bin/zookeeper-server-stop.sh

bin/kafka-server-stop.sh

补充：

启动Kafka服务端时出错

OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000c0000000, 1073741824, 0) failed; error='Cannot allocate memory' (errno=12)

原因就是内存无法分配的问题（这要看遇到的具体是什么了）

现执行命令 free -m 查看内存是不是还有，最主要的是，看有没有交换空间 swap（这很重要）。如果没有交换空间或者交换空间比较小，要先安装交换空间或者增大空间

（1）、root权限下，创建swapfile：

# dd  if=/dev/zero  of=swapfile  bs=1024  count=500000  （有时会遇到dd命令不识别可能是你安装过一次了，没事，先把swapfile删除就ok了）

（2）、将swapfile设置为swap空间

# mkswap swapfile

（3）、启用交换空间：

# swapon  swapfile

（删除交换空间 # swapoff swapfile）

至此增加交换空间的操作结束了，可以使用free -m 命令查看swap空间大小是否发生变化；