Kafka之Linux下安装

标签：html   pac   art   jdk1.8   ffffff   使用   down   输入   nec   

软件环境

CentOS6.5

JDK1.8

kafka_2.10-0.10.0.0

安装Java Jdk

省略...

下载安装文件： http://kafka.apache.org/downloads.html

解压下载的kafka

tar -zxvf kafka_xxx.tgz

cd kafka_xxx

安装Zookeeper

启动zk有两种方式，第一种是使用kafka自带的一个zk。

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

另一种是使用其它的zookeeper，可以位于本机也可以位于其它地址。

这种情况需要修改config下面的sercer.properties里面的zookeeper地址

例如zookeeper.connect=ip:2181

安装省略

防火墙开启默认的端口2181和9092 

启动kafka

进入kafka_xxx目录

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

创建topic

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

创建一个名为mytopic的topic，只有一个副本，一个分区。

通过list命令查看刚刚创建的topic

bin/kafka-topics.sh -list -zookeeper localhost:2181

启动producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic

启动之后就可以发送消息了,随便输入 按回车

按Ctrl+C退出发送消息

启动consumer

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic mytopic --from-beginning

启动consumer之后就可以在console中看到producer发送的消息了

也可以开启两个终端，一个发送消息端，一个接受消息端 来进行测试。

kafka开机自动启动

未完待续

Kafka之Linux下安装

标签：html   pac   art   jdk1.8   ffffff   使用   down   输入   nec   

原文地址：https://www.cnblogs.com/zengnansheng/p/10389752.html