Kafka之Linux下安装

Posted zengnansheng

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka之Linux下安装相关的知识,希望对你有一定的参考价值。

软件环境

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下安装的主要内容,如果未能解决你的问题,请参考以下文章

Kafka之Linux下安装

Apache KafkaKafka安装及简单示例

linux安装下安装nginx

Linux下安裝Oracle database內核參數設置

PythonWindows, Linux/UNIX, Mac OS X 下安裝 Python

网络配置_在Vmware下安装好Linux的虚拟机后