kafka教程(一):hello,world

下载

kafka的官方网站是http://kafka.apache.org, 到官网下载最新版
kafka_2.11-1.0.0.tgz,如下图

解压kafka_2.11-1.0.0.tgz,其目录结构如下

1
2
3
4
5
6
7
8
9
10
11
12

➜  kafka_2.11-1.0.0 ll

# 存放的kafka的一系列脚本,用于操作kafka
bin
# kafka所需的配置
config
# kafka所需要的jar包
libs
LICENSE
NOTICE
# 文档
site-docs

运行第一个实例

运行第一个实例: 生产者向kafka发送一条消息,消费者从kafka中接收一条消息

1. 下载并配置zookeeper

   kafka依赖zk,通过zk来管理各种数据和元数据,kafka内部自带了zk,我们单独下载一个zk.

   zk官网网址:http://zookeeper.apache.org, 我们下载zookeeper-3.4.11版本,下面是我zoo.cfg中的配置

   1 2 3 4 5 6

   tickTime=2000 initLimit=10 syncLimit=5 dataDir=/library/zookeeper-3.4.11/data clientPort=2181