1、kafka官网:http://kafka.apache.org/downloads
jdk:https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
参考书籍:Apache kafka实战
下载安装如下所示:
我下载的是kafka_2.11-2.1.0
然后点击如下进行下载即可:
下载jdk,根据自己的需求下载所需的jdk版本,64位还是32位的。我下载的32位的jdk-8u191-linux-i586.tar.gz。
然后将下载好的jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz传输到自己的机器上面,找个特定的目录,这样方便自己进行管理。
2、然后将jdk-8u191-linux-i586.tar.gz和kafka_2.11-2.1.0.tgz。解压缩到特定的目录里面,方便管理。
配置jdk的环境变量:
3、启动服务器,配置好jdk和kafka就可以启动了,启动之前要先启动zookeeper服务器,zookeeper是为kafka提高协调服务的工具。kafka已经内置了一个zookeeper服务器以及一些启动脚本。
启动好zookeeper以后,然后启动kafka服务器。
[KafkaServer id=0] started (kafka.server.KafkaServer)说明kafka服务器启动成功,默认的服务端口是9092。
4、创建topic,服务器启动后,我们需要创建一个主题(topic)用于消息的发送和接受。这一步将创建一个名称为test的topic,该topic只有一个分区(partition),且该partition也只有一个副本(replica)处理消息。
注意:为了要创建topic,要保证刚才启动的zookeeper和kafka的终端不被关闭。打开一个新的终端。
然后topic创建成功了,使用命令查看该topic的状态。
5、发送消息,即生产消息。kafka默认提供了脚本工具可以不断的接受标准输入并将他们发送到kafka的某个topic上面,用户在控制台终端下启动该命令,输入一行文本数据,然后该脚本将改行文本封装成一条kafka消息发送给指定的topic。打开新的终端,执行命令。
6、消费消息,消费者,kafka提供了一对应的脚本用于消费某些topic下的消息并打印到标准输出。打开新的终端。执行如下命令。
待续......