kafka教程(一):hello,world

下载

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

kafka下载

解压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