南京h5制作公司seo营销外包公司

本文介绍kafka单机环境的搭建及可视化环境配置，虽然没有java代码，但是麻雀虽小五脏俱全，让大家在整体感官上对kafka有个认识。在文章的最后，我介绍了几个重要的配置参数，供大家参考。

0、环境

• kafka：2.8.0

1、启动zookeeper

kafka本身自带了一个zookeeper，我们直接用这个就行，当然你也可以用你现成的zookeeper。下面是启动zookeeper的命令：

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

注意：zookeeper的端口默认是2181，如果你要修改，修改zookeeper.properties文件。

2、kafka配置及启动

2.1、配置

打开config/server.properties文件，找到listeners配置，修改成你想要改成的端口。

listeners=PLAINTEXT://localhost:9092

注意，如果你的zookeeper不是默认，同样在server.properties文件里，找到zookeeper.connect参数，改成你实际的地址和端口。

2.2、启动

下面咱们启动kafka：

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

能够看到kafka输出了大段的日志，在最后有提示kafka启动成功的提示。

3、测试

3.1、创建一个topic

bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic testk --
partitions 2  --replication-factor 1

创建了topic名称是testk，它有2个partition，有一个副本。注意这里的副本包含topic本身，也就是说，此时没有副本。
下面查看一个topic的详细信息：

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic testk

3.2、创建producer、consumer

先创建一个producer（基础概念我就不多说了）：

bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic testk

重新打开一个终端窗口，我们用来创建consumer：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic testk

现在有两个窗口，我们可以在producer中输入消息，能够在consumer窗口看到收到的消息。注意：–from-beginning：指的是从头开始消费。

4、监控工具kafka manager

上面我在本地安装并配置了一个kafka实例，并利用kafka提供的命令行工具，分别创建了一个producer和consumer。但是不直观，这里我们配置一个kafka可视化工具， 利用工具能更直观。

我们这里使用的工具是kafka manager，现在改名字了，叫CMAK。下载地址： https://github.com/yahoo/CMAK。

4.1、启动

解压后，进入conf文件夹，打开application.conf文件。这里我们要配置zookeeper的地址，如下图：

好了，可以启动了。CMAK home目录下执行：

bin/cmak -Dhttp.port=9001

-Dhttp.port指定了访问端口，你也可以用默认，默认端口是9000。好了，咱们访问一下。

4.2、利用CMAK配置集群

上图我标记的很清楚了，不多解释了，最后保存即可。这里要注意下，选了JMX Polling，我们要修改一下kafka的启动命令，指定JMX的监听端口。

JMX_PORT=9999  bin/kafka-server-start.sh config/server.properties

等kafka启动完成后，咱们再看一下配置后的效果：

相对比较简单，我就不多说了。最后我说几个重要的配置参数。

5、几个重要的kafka配置参数

• log.dirs：broker要使用的文件目录路径，可以多个，逗号分割。
• zookeeper.connect：指定了zookeeper的地址和端口，如：localhost:2181，可以多个，逗号分割。
• listeners：客户端连接kafka时，使用的协议、主机名和端口。如：PLAINTEXT://localhost:9092，其中PLAINTEXT表示明文传输。用户也可以用ssl加密的方式。
• log.retention.{hour|minutes|ms}：一条消息保存多长时间。当数据库用就将这个值调大。
• log.retention.bytes：消息保存的总磁盘容量。默认值-1，表示没有上限。
• message.max.bytes: 最大消息的大小。默认值1000012，不到1M，实际的生产环境超过1M的消息太多了，建议调大点。

好了，今天就到这里了。内容不少，希望大家能理解。
//~~