kafka入门篇-- 1. zookeeper安装以及kafka安装
时间:2020-03-24
本文章向大家介绍kafka入门篇-- 1. zookeeper安装以及kafka安装,主要包括kafka入门篇-- 1. zookeeper安装以及kafka安装使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
在学习kafka之前,需要先安装zookeeper
进入要下载的版本的目录,选择 .tar.gz
文件下载,下载链接:http://archive.apache.org/dist/zookeeper/
zookeeper是一套分布式协调服务框架,那么如何理解分布式协调:主要用来解决分布式环境当中多个进程之间的同步控制,让他们有序的去访问某种临界资源,防止造成“脏数据”的后果.
下载完成zookeeper之后,解压到指定目录,然后在该文件下创建data以及logs文件,存放数据以及日志,然后进入conf目录,将zoo_sample.cnf复制一份到当前目录,并修改名称为zoo.cnf
在其中添加下述信息:
dataDir=/Users/mac/installed/apache-zookeeper-3.6.0-bin/data dataLogDir=/Users/mac/installed/apache-zookeeper-3.6.0-bin/logs
正阳zookeeper就安装完毕了
接下来看一下一些常用命令:
进入 bin
目录,启动、停止、重启和查看当前节点状态
./zkServer.sh start ./zkServer.sh stop ./zkServer.sh restart ./zkServer.sh status
接下来根据官网安装一下kafka
http://kafka.apache.org/quickstart
先启动zookeeper,然后使用命令
bin/kafka-server-start.sh -daemon config/server.properties
启动服务,这个就是使用守护进程
然后我们可以简单创建一个topics
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
可以使用,查看所有的topic
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
kafka带有脚本测试工具可以帮助测试,起一个消息生产者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
一个消息接受者
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
--from-beginning意味着从头开始接受消息,如果该参数,则之前的消息就不会接收到
原文地址:https://www.cnblogs.com/yangshixiong/p/12553172.html
- Java中三种Set类型用法、性能大比拼
- Android基础总结(5)——数据存储,持久化技术
- 如何突破Windows环境限制打开“命令提示符”
- 【Spark研究】Spark之工作原理
- Java中泛型使用的必要性
- “一切都是消息”--MSF(消息服务框架)之【发布-订阅】模式
- Android基础总结(4)——广播接收器
- “一切都是消息”--MSF(消息服务框架)之【请求-响应】模式(点对点)
- “老坛泡新菜”:SOD MVVM框架,让WinForms焕发新春
- 解决服务器SID引起虚拟机不能加入AD域用户,无法远程登录的问题
- 【Python环境】如何使用 Docker 快速配置数据科学开发环境?
- Java中UUID的2种创建方法——有代码实例
- 使用“消息服务框架”(MSF)实现分布式事务的三阶段提交协议(电商创建订单的示例)
- Android基础总结(3)——UI界面布局
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 一天一大 lee(二叉树的层平均值)难度:简单-Day20200912
- 一天一大 lee(组合总和 II)难度:中等-Day20200910
- 一天一大 lee(组合总和 III)难度:中等-Day20200911
- 一天一大 lee(翻转二叉树)难度:简单-Day20200916
- 一天一大 lee(表示数值的字符串)难度:中等-Day20200902
- 一天一大 lee(单词搜索)难度:简单-Day20200913
- 一天一大 lee(克隆图)难度:中等-Day20200813
- 一天一大 lee(相同的树)难度:简单-Day20200807
- 一天一大 lee(解数独)难度:困难-Day20200915
- 一天一大 lee(复原IP地址)难度:中等-Day20200809
- 一天一大 lee(计数二进制子串)难度:简单-Day20200810
- 一天一大 lee(打家劫舍 III)难度:中等-Day20200805
- 一天一大 lee(课程表)难度:中等-Day20200804
- 一天一大 leet(二叉树展开为链表)难度:中等-Day20200802
- 一天一大 leet(字符串相加)难度:简单-Day20200803