文档章节

Kafka安装

k
 kunping
发布于 2017/03/22 19:30
字数 282
阅读 125
收藏 2

1、安装JDK(1.8.x)

2、安装zookeeper

    a. 下载zookeeper-3.4.9.tar.gz

    b. 解压到D:\Install目录下

    c. 进入D:\Install\zookeeper-3.4.9\conf目录,将zoo_sample.cfg重名为zoo.cfg,并做以下修改:

dataDir=D:/Install/zookeeper-3.4.9/data
clientPort=2181

    d. 双击D:\Install\zookeeper-3.4.9\bin目录下的zkServer.cmd启动zookeeper

#linux下启动zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties

3、安装Kafka

    a. 下载kafka_2.11-0.10.1.1.tgz

    b. 解压到D:\Install目录下

    c. 进入D:\Install\kafka_2.11-0.10.1.1\config

        修改server.properties:

log.dirs=D:/tmp/kafka-logs

    修改zookeeper.properties

dataDir=d:/tmp/zookeeper

    d. 进入D:\Install\kafka_2.11-0.10.1.1,启动Kafka服务

#window
.\bin\windows\kafka-server-start.bat .\config\server.properties

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

    e. 创建topic,=> kafka-spark-demo

#window
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

#linux
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    f. 查看topic   

#window
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

#linux
./bin/kafka-topics.sh --list --zookeeper localhost:2181

    g. 启动Producer

#window
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

#linux
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

    h. 启动Comsumer

#window
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic test

#linux
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test

    i. 测试,在Producer上输入消息,即可在Consumer上面看到输出

4、Kafka其他命令

#删除topic
./bin/kafka-topics.sh  --delete --zookeeper localhost:2181 --topic test

 

© 著作权归作者所有

k
粉丝 3
博文 61
码字总数 29867
作品 0
深圳
私信 提问

暂无文章

分布式协调服务zookeeper

ps.本文为《从Paxos到Zookeeper 分布式一致性原理与实践》笔记之一 ZooKeeper ZooKeeper曾是Apache Hadoop的一个子项目,是一个典型的分布式数据一致性的解决方案,分布式应用程序可以基于它...

ls_cherish
今天
4
0
redis 学习2

网站 启动 服务端 启动redis 服务端 在redis 安装目录下 src 里面 ./redis-server & 可以指定 配置文件或者端口 客户端 在 redis 的安装目录里面的 src 里面 ./redis-cli 可以指定 指定 连接...

之渊
昨天
2
0
Spring boot 静态资源访问

0. 两个配置 spring.mvc.static-path-patternspring.resources.static-locations 1. application中需要先行的两个配置项 1.1 spring.mvc.static-path-pattern 这个配置项是告诉springboo......

moon888
昨天
4
0
hash slot(虚拟桶)

在分布式集群中,如何保证相同请求落到相同的机器上,并且后面的集群机器可以尽可能的均分请求,并且当扩容或down机的情况下能对原有集群影响最小。 round robin算法:是把数据mod后直接映射...

李朝强
昨天
4
0
Kafka 原理和实战

本文首发于 vivo互联网技术 微信公众号 https://mp.weixin.qq.com/s/bV8AhqAjQp4a_iXRfobkCQ 作者简介:郑志彬,毕业于华南理工大学计算机科学与技术(双语班)。先后从事过电子商务、开放平...

vivo互联网技术
昨天
24
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部