文档章节

zookeeper-kafka环境搭建,生产者消费者终端测试

h
 hhjian
发布于 2017/09/10 11:14
字数 160
阅读 17
收藏 0

(一)、zookeeper下载

zookeeper-3.4.10

(二)、kafaka下载

kafka_2.11

(三)、启动zookeeper

./zkServer.sh start

(四)、启动kafka

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

(五)、创建主题

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic sf

  • replication-factor 服务个数,集群数
  • partition 分区数
  • list 查看主题

(六)、测试生产者

./kafka-console-producer.sh --broker-list localhost:9092 --topic sf

  • broker-list 消息代理服务器,ip端口在server.properties中

(七)、测试消费者

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sf --from-beginning

  • bootstrap-server 引导消息服务器,ip端口在server.properties中
  • from-beginning 获取所有消息,不设置则只接受当前的

© 著作权归作者所有

共有 人打赏支持
h
粉丝 0
博文 40
码字总数 10160
作品 0
湛江
程序员
Zookeeper+Kafka的单节点standalone配置

Zookeeper+Kafka的单节点standalone配置 环境描述:Ubuntu16.04 server系统,在系统上搭建Java环境,jdk的版本为1.8或更高,我的服务器IP地址为192.168.0.106。 1.使用命令mkdir /opt/data在...

ALittleMoreLove
07/31
0
0
Kafka 单机和分布式环境搭建与案例使用

Kafka 单机和分布式环境搭建与案例使用 目录(?)[+] 一、单机环境搭建 官方参考文章: http://kafka.apache.org/quickstart 1、下载和解压安装包 这里下载了zookeeper和kafaka两个安装包,下载...

yucaifu1989
04/19
0
0
Mac 本地搭建 Kafka+ZooKeeper

从 https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/stable/ 下载 ZooKeeper 并解压缩。 修改配置文件,将 改成 然后启动 ZooKeeper 查看 下载 Kafka,解压缩,启动 打开新的终端,创...

wuliong
2017/11/04
0
0
springboot整合kafka

为了方便起见安装zk集群和kafka集群我就不详细说明了,以下摘自https://www.cnblogs.com/lentoo/p/7785004.html,文章部分内容我做了修改,因为版本或者命令改变 kafka集群搭建(windows环境...

落叶清风
10/09
0
0
zookeeper+kafka集群搭建

基本环境: 操作系统 : ubuntu-16.04.2 jdk : jdk1.8.0144 zookeeper : zookeeper3.4.6 kafka : kafka2.12-0.11.0.0 搭建过程中,用三台虚拟机来实现环境的配置,3台虚拟机的ip如下: 19...

王福林
09/13
0
0

没有更多内容

加载失败,请刷新页面

加载更多

初级开发-编程题

` public static void main(String[] args) { System.out.println(changeStrToUpperCase("user_name_abc")); System.out.println(changeStrToLowerCase(changeStrToUpperCase("user_name_abc......

小池仔
今天
6
0
现场看路演了!

HiBlock
昨天
16
0
Rabbit MQ基本概念介绍

RabbitMQ介绍 • RabbitMQ是一个消息中间件,是一个很好用的消息队列框架。 • ConnectionFactory、Connection、Channel都是RabbitMQ对外提供的API中最基本的对象。Connection是RabbitMQ的s...

寰宇01
昨天
10
0
官方精简版Windows10:微软自己都看不过去了

微软宣布,该公司正在寻求解决方案,以减轻企业客户的Windows 10规模。该公司声称,企业客户下载整个Windows 10文件以更新设备既费钱又费时。 微软宣布,该公司正在寻求解决方案,以减轻企业...

linux-tao
昨天
19
0
TypeScript基础入门之JSX(二)

转发 TypeScript基础入门之JSX(二) 属性类型检查 键入检查属性的第一步是确定元素属性类型。 内在元素和基于价值的元素之间略有不同。 对于内部元素,它是JSX.IntrinsicElements上的属性类型...

durban
昨天
12
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部