-- Start

点击此处观看本系列配套视频

首先我们从一个最简单的例子开始，那就是kafka 集群只有一个broker。

1. 启动 ZooKeeper

Kafka 使用了 ZooKeeper，所以我们需要先启动 ZooKeeper。假设你的 Kafka 解压缩到目录 D:\0_Shangbo\App\kafka\kafka_2.12-1.1.0。首先，我们需要修改一下 config 目录下 zookeeper.properties 属性文件，将下面这行

dataDir=/tmp/zookeeper

替换成自己的目录（确保你的目录存在），如：

dataDir=D:/0_Shangbo/App/kafka/data/zookeeper

然后，在 Windows 的命令提示符中执行如下的命令来启动 ZooKeeper。

set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0
cd %KAFKA_HOME%/bin/windows
zookeeper-server-start.bat %KAFKA_HOME%/config/zookeeper.properties

如果启动 ZooKeeper 时出现下面的错误，安装一个 jdk1.8 64位试一试吧。

Unrecognized VM option 'UseCompressedOops'
Error: Could not create the Java Virtual Machine.
Error: A fatal exception has occurred. Program will exit.

2. 启动 Kafka broker

在Windows 下启动 Kafka border 之前，我们需要修改一下 config 目录下的 server.properties 属性文件，将如下行

log.dirs=/tmp/kafka-logs

替换成自己的目录（确保你的目录存在），如：

log.dirs=D:/0_Shangbo/App/kafka/data/kafka/broker0

修改完之后，新打开一个命令提示符，执行如下的命令来启动 Kafka broker

set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0
cd %KAFKA_HOME%/bin/windows
kafka-server-start.bat %KAFKA_HOME%/config/server.properties

3.创建 topic

新打开一个命令提示符，下面的命令创建了一个名为topic0 的topic。

set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0
cd %KAFKA_HOME%/bin/windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic0

你也可以运行下面的命令显示已经创建的 topic

kafka-topics.bat --list --zookeeper localhost:2181

4.发送消息

下面的命令发送一条消息到topic0。

set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0
cd %KAFKA_HOME%/bin/windows
kafka-console-producer.bat --broker-list localhost:9092 --topic topic0
This is a message

5. 接收消息

下面的命令从topic0 中接收消息。

set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0
cd %KAFKA_HOME%/bin/windows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic0 --from-beginning

-- 更多参见：Kafka 精萃
-- 声明：转载请注明出处
-- Last Edited on 2018-06-09
-- Written by ShangBo on 2014-09-03
-- End

Kafka 只有一个broker的例子相关推荐

Kafka有多个broker的例子——重点是Replicas和lsr和Leader位置
1. 启动 ZooKeeper 首先还是启动 ZooKeeper. set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0 cd %KAFKA_H ...
Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常？
欢迎支持笔者新作:<深入理解Kafka:核心设计与实践原理>和<RabbitMQ实战指南>,同时欢迎关注笔者的微信公众号:朱小厮的博客. 欢迎跳转到本文的原文链接:https: ...
Kafka学习之第一个例子（一）
目录 1. kefka简介 2. 安装kafka 3. 部署kafka集群 4. 创建Topic并使用生产者消费者生产消费消息 1. Kafka 简介 Kafka 是一个高吞吐量的分布式发布订阅消息系 ...
【原创】大叔问题定位分享（4）Kafka集群broker节点从zookeeper上消失
kafka_2.8.0-0.8.1 一现象生产环境一组kafka集群经常发生问题,现象是kafka在zookeeper上的broker节点消失,此时kafka进程和端口都在,然后每个broker都 ...
Kafka之Controller(Broker的领导者)
什么是Controller 在Kafka集群中,某个Broker将被选举出来担任一种特殊的角色,其用于管理和协调Kafka集群,即管理集群中的所有分区的状态并执行相应的管理操作. 每个Kafka集群任 ...
一个简单的例子学会github repository的webhook
2019独角兽企业重金招聘Python工程师标准>>> github的webhook是个有用的功能,允许开发人员指定一个服务器的url.当开发者对github仓库施加操作,比如提交代 ...
.net中的对象序列化(1)：序列化是什么, 以及一个简单的例子
1. 为什么需要序列化,什么是序列化对于一个程序来说, 使用到的对象都是存在于内存中的.如果想保存这些对象的运行时状态, 或者需要在不同进程或者网络间传递对象,就需要序列化. 序列化就是讲运行中的对 ...
一个具体的例子学习Java volatile关键字
相信大多数Java程序员都学习过volatile这个关键字的用法.百度百科上对volatile的定义: volatile是一个类型修饰符(type specifier),被设计用来修饰被不同线程访问和 ...
一个简单的例子看java线程机制
一个简单的例子看java线程机制作者: zyf0808 发表日期: 2006-03-26 11:20 文章属性: 原创复制链接 import java.util.*; public class T ...

Kafka 只有一个broker的例子