在iOS控制系统上加装最新消息堆栈kafka

概要

Kafka 是两个由 LinkedIn 合作开发的分布式系统最新消息控制系统，它于2011年年末开放源码，那时由知名的 Apache 促进会保护与合作开发。 Kafka 采用 Scala 同时实现，被用于 LinkedIn 的公益活动流和营运信息处理的管线，那时也被众多网络民营企业广为地用于报文管线和最新消息控制系统， Kafka 是如前所述最新消息正式发布﹣订户商业模式同时实现的最新消息控制系统。

浏览

官方网站浏览镜像：https://kafka.apache.org/downloads我浏览的是Scala 2.12 – kafka_2.12-3.1.0.tgz

加装

kafka只须要Cogl浏览的LiveCD要是，我这儿Cogl的方向是D:\kafka_2.12-3.1.0，kafka的运转须要倚赖zookeeper，相关zookeeper的Windows加装请看这儿，现阶段版早已内建了zookeeper，因此不须要再加装zookeeper。

配置

想要启动kafka须要修改kafka配置文件和zookeeper配置文件，配置文件都在跟目录下面的config文件夹下。

kafka配置

kafka 服务端配置在server.properties中。kafka配置须要修改两处配置文件：listeners 和 log.dirs

• listeners：服务器监听的地址，修改如下：

listeners=PLAINTEXT://localhost:9092

log.dirs：日志文件修改为自定义的日志目录，我的是

log.dirs=D:/kafka_2.12-3.1.0/logs

zookeeper配置

zookeeper配置文件为zookeeper.properties，只需修改一处，dataDir：zookeeper存储数据的方向修改自定义的目录，要用反斜杠/

dataDir=D:/kafka_2.12-3.1.0/data

测试

接下来进入测试阶段：进入kafka加装根目录下，地址栏输入cmd，然后回车，通过命令行启动之后都不要关闭窗口。

启动zookeeper

先启动zookeeper，启动命令如下：

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

在这儿插入图片描述

启动kafka

再在地址栏输入cmd

启动kafka-server

.\bin\windows\kafka-server-start.bat .\config\server.properties

如果启动kafka失败，并出现以下异常，删除logs文件夹下的meta.properties文件即可。

The Cluster ID xxxx doesn’t match stored clusterIdSome(finN2zUTRWaXMomXCknRew)in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.

启动kafka-topics

创建两个名为test的topic命令如下：

.\bin\windows\kafka-topics.bat --create --bootstrap-server  localhost:2181--replication-factor1--partitions1--topic test

启动之后，kafka-topics处于等待创建topic状态，一段时间内如果不createTopic，kafka-topics将自动断开

启动生产者

命令如下：

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092--topic test

启动生产者之后就可以发送最新消息了

启动消费者

命令如下：

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092--topic test

启动消费者之后生产者发送的最新消息，消费者端就能收到了。

在生产端发送最新消息，可以看到消费端就收到了

至此，最新消息堆栈kafka就加装完毕了。

能力一般，水平有限，如有错误，请多指出。如果对你有用点个关注给个赞呗

更多文章可以关注一下我的微信公众号suncodernote