Docker下安装kafka，以及java实现生产者的过程

我们的环境是centos7

第一步：安装 Docker 我们要是第一安装docker 会有很多坑要踩，

这里我这直接说，避开坑的安装方式。

第一步：更新 Linux 的内核， yum update

第二步：通过管理员安装 docker 容器 sudo yum install docker （切记一定要这么安装）

第三步：启动docker容器 systemctl start docker

第四步：检查docker容器是否启动成功查看容器状态 systemctl status docker

因为kafka需要 zookeeper 所以我们需要先

1. 安装zookeeper docker run -d –name zookeeper -p 2181:2181 -t wurstmeister/zookeeper

2.安装kafka

docker run -d –name kafka -p 9092:9092

-e KAFKA_BROKER_ID=0

-e KAFKA_ZOOKEEPER_CONNECT=140.143.134.205:2181

-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://140.143.134.205.128:9092

-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

中间两个参数的140.143.134.205:改为本机的IP地址，不设置可能会导致在别的机器上访问不到kafka。

测试kafka

1.首先要从docker中进入kafka docker exec -ti kafka /bin/bash

2.进入kafka所在目录中 cd opt/kafka_2.12-1.1.0/

接下来我们可以直接使用kafka 自己命令行的方式，测试自己的生产和消费

1.首先创建topic bin/kafka-topics.sh –create –zookeeper 140.143.134.205:2181 –replication-factor 1 –partitions 1 –topic kafka-test

2.我们先来一个生产者 bin/kafka-console-producer.sh –broker-list 140.143.134.205:9092 –topic kafka-test

3. 来一个消费者 bin/kafka-console-consumer.sh –bootstrap-server 140.143.134.205:9092 –topic kafka-test –from-beginning

接下来我们看java代码中怎么实现一个生产者

先看看效果图

这个图就是，右侧是java程序在生产，左侧的命令行接收

智云一二三科技