您当前的位置:首页 >> 买车
Docker下安装kafka,以及java实现生产者的过程
发布时间:2019-08-09
 

我们的环境是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

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

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

先看看效果图

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

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

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