ArcGIS GeoEvent Server与Kafka对接系列：01-kafka单节点部署(Linux)

一、基础环境

操作系统：Linux Redhat 6.9
JDK:jdk1.8.0_152
Kafka版本：kafka_2.11-2.1.0

二、部署过程

1.部署JDK

过程略.

2.部署Kafka

第一步：下载安装包

https://www.apache.org/dyn/closer.cgi?path=/kafka/2.1.0/kafka_2.11-2.1.0.tgz
下载下来之后解压：

tar -xzf kafka_2.11-2.1.0.tgz
cd kafka_2.11-2.1.0

第二步：修改配置文件：

配置config/zookeeper.properties文件的zookeeper数据目录：

配置config/server.properties文件的监听IP和kafka的日志目录：

备注：官方的入门手册里是不需要修改的，不修改的情况下可以满足单机的测试，但为了方便以后的分布式测试，所以提前修改！
另外，如果是测试环境的话，数据不用的情况下，可以先关闭zookeeper和kafka-server，再把这两个目录下的内容全部删除掉，再启动zookeeper和kafka-server.

第三步：启动zookeeper和kafka-server：

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

备注：zookeeper是内置的，也可以采用外置的zookeeper。

bin/kafka-server-start.sh config/server.properties

第四步：创建主题(topic)

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

创建完成之后还可以检查是否已经创建主题成功：

bin/kafka-topics.sh –list –zookeeper 192.168.1.201:2181

第五步：发送消息

bin/kafka-console-producer.sh –broker-list 192.168.1.201:9092 –topic test
This is a message
This is another message

这是使用了内置提供的控制台工具，可以在控制台中发送数据至kafka。

第六步：接收消息

bin/kafka-console-consumer.sh –bootstrap-server 192.168.1.201:9092 –topic test –from-beginning
This is a message
This is another message

这是使用了内置提供的控制台工具，可以在控制台中接收到kafka的数据，由于我们是先启动数据生成者，所以在命令的最后加入了一个参数–from-beginning，疑问着从最开始的数据获取。

转载自：https://blog.csdn.net/peckerzeng/article/details/86299014