ITPub博客

首页 > 应用开发 > IT综合 > Linux kafak安装与启动

Linux kafak安装与启动

原创 IT综合 作者:百联达 时间:2015-12-29 17:30:16 0 删除 编辑

一:背景

Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢?

首先让我们看几个基本的消息系统术语:

?Kafka将消息以topic为单位进行归纳。
?将向Kafka topic发布消息的程序成为producers.
?将预订topics并消费消息的程序成为consumer.
?Kafka以集群的方式运行,可以由一个或多个服务组成,每个服务叫做一个broker.
producers通过网络将消息发送到Kafka集群,集群向消费者提供消息。

我们当前使用的kafak版本信息:kafka_2.11-0.9.0.0.tgz

二:安装

tar -zxvf kafka_2.11-0.9.0.0.tgz  -C /usr/local

三: 启动

1.启动zookeeper

启动zk有两种方式,第一种是使用kafka自己带的一个zk。 bin/zookeeper-server-start.sh config/zookeeper.properties &

另一种是使用其它的zookeeper,可以位于本机也可以位于其它地址。这种情况需要修改config下面的server.properties里面的zookeeper地址 。例如zookeeper.connect=localhost:2181


2.启动kafka

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

四:创建topic

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
创建一个名为test的topic,只有一个副本(与broker的个数对应),一个分区。



通过list命令查看刚刚创建的topic
./bin/kafka-topics.sh -list -zookeeper localhost:2181


五:启动producer并发送消息

./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
启动之后就可以发送消息了
比如 
test
hello boy
按Ctrl+C退出发送消息

七:启动consumer

./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
启动consumer之后就可以在console中看到producer发送的消息了
可以开启两个终端,一个发送消息,一个接受消息。




bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
启动之后就可以发送消息了
比如 
test
hello boy
按Ctrl+C退出发送消息

6.启动consumer

bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning
启动consumer之后就可以在console中看到producer发送的消息了
可以开启两个终端,一个发送消息,一个接受消息。


来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/28624388/viewspace-1966761/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论
10年以上互联网经验,先后从事过制造业,证券业,物业行业和物流行业信息系统和互联网产品的研发,6年系统架构经验。最近关注Kubernetes微服务架构和Istio微服务治理框架。

注册时间:2013-02-05

  • 博文量
    320
  • 访问量
    1024600