kafka——2.11 单机部署 与topic基础简单应用
一.要使用kafka首先要配置启动好zookeeper
1.在zookeeper的conf目录里 执行:
cp zoo_sample.cfg zoo.cfg
2.打开zoo.cfg的文件
命 令 :vi zoo.cfg
dataDir=/tmp/zookeeper (虽然给出这个路径给你,但是系统并没有,要你自己创建的,你可以不按这个路径)
dataLogDir=/tmp/zookeeperlog (这是我另外夹的用来存放日志文件)
6):启动 zookeeper
在zookeeper目录下
命令 : bin/zkServer.sh start
二。启动kafka
1, 下载地址 http://mirrors.shu.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz
2,解压
3.启动kafka
命令:new bin/kafka-server-start.sh config/server.properties &
运行之后不管成功否它都会在你的kafka包下生成一个 new.out的文件
用topic检验kafka是否成功
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic lol //创建一个lol的topic
//查看 topic是否成功
bin/kafka-topics.sh --list --zookeeper localhost:2181
//把kafka的生产者启动来
//命令 :
//另开一个终端(创建新的),把消费者启动起来:
过时的命令(博主踩过的坑)
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic lol —from-beginning
现用的命令!!!(不要看错了这才是真正的)
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic lol --from-beginning
在生产者终端输入数据,消费者马上就会消费显示出来
这就完成了一个topic(话题)的简单操作
消费者(kafka数据源被称为生产者,数据目的地被称为消费者)
至此完毕!!
如果觉得可以请关注一下!!
附上一篇散文片段作为消遣: 纪伯伦 沙与沫
仅仅在昨天,我认为我自己只是一个碎片,无韵律地在生命的穹苍中颤抖。
现在我烧得,我就是那穹苍,一切生命都是在我里面有韵律地转动的碎片。
他们在觉醒的时候对我说:“你和你所居住的世界,只不过是无边海洋的无边沙岸上的一粒砂子。”
在梦里我对他们说:“我就是那无边的海洋,大千世界只不过是我的沙岸上的沙粒。”
只有一次把我窘得哑口无言。就是当一个人问我,“你是谁?”的时候。
想到神的第一个念头是一个天使。
说到神的第一个字眼是一个人。
我们是有海洋以前千万年的扑腾着、飘游着、追求着的生物,森林里的风把语言给予了我们。
那么我们怎能以昨天的声音来表现我们心中的远古年代呢?
斯芬克斯只说过一次话。斯芬克斯说:“一粒沙子就是一片沙漠,一片沙漠就是一粒沙子;现在再让我们沉默下去吧。”
我听到了斯芬克斯的话,但是我不懂得。
转载于:https://www.cnblogs.com/lppz/p/9984884.html
kafka——2.11 单机部署 与topic基础简单应用相关推荐
- graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二)
graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylo ...
- Kafka单机部署学习演示案例
Kafka 单机部署演示 前置准备 虚拟机配置: 内存:3G 处理器:1 核数:1 (一)kafka 安装 去kafka官网下载稳定版本到Linux服务器中进行解压安装.下载链接,我这里使用的是2.7 ...
- KAFKA 最新版 单机安装、配置、部署(linux环境)
文章目录 一.基础软件下载 1. JDK 2. KAFKA 3. ZOOKEEPER 二.zookeeper配置启动 2.1. 解压 2.2. 配置环境变量 2.3. 刷新环境变量 2.4. 配置文件 ...
- 1、nifi-1.9.2介绍、单机部署及简单验证
Apache NiFi系列文章 1.nifi-1.9.2介绍.单机部署及简单验证 2.NIFI应用示例-GetFile和PutFile应用 3.NIFI处理器介绍.FlowFlie常见属性.模板介绍和 ...
- graylog+kafka+zookeeper(单机测试及源码),graylog收集kafka(脚本创建发布订阅方式)存储的消息(四)
graylog+kafka+zookeeper(单机测试及源码),graylog收集kafka(脚本创建发布订阅方式)存储的消息(四) 问题背景 graylog+kafka+zookeeper(单机测 ...
- graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三)
graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylog组件部署 ...
- FastDFS单机部署安装
FastDFS单机部署安装 文章目录 FastDFS单机部署安装 前言 1:服务器规划 2:安装包 3:所有tracker和storage节点都执行如下操作 3.1:安装所需的依赖包 3.2:安装li ...
- Kafka入门(一) 概述、部署与API的简单使用
Kafka入门(一) 概述.部署与API的简单使用 MQ 传统架构的问题 MQ简介 MQ的优缺点 优点 缺点 同步与异步 P2P模式 订阅发布模式 Kafka概述 简介 特点 名称解释 Broker ...
- java+鼠标滑过变小手_Kafka单机部署
一.kafka介绍及原理 kafka是由Apache软件基金会发布的一个开源流处理平台,由Scala和Java编写.它是一种高吞吐量的分布式发布的订阅消息系统,它可以处理消费者规模的网站中的所有动作流 ...
最新文章
- 别再说学不会:超棒的Numpy可视化学习教程来了
- 谷歌Jeff Dean团队提出利用深度学习对「电子健康记录」数据进行分析,可提高医疗诊断预测的准确性
- MySQL的主从复制主从同步
- linux使用qemu教程,Linux:使用 QEMU 测试 U-BOOT的步骤
- 第三次学JAVA再学不好就吃翔(part32)--方法重写
- 北理计算机教案,北理工版三年级信息技术教案重点.docx
- 高阶函数(Higher-order function)
- 比特斯拉酒瓶更贵!小鹏汽车推出“金属麻将”:1999元
- (转)cocos2d-x学习笔记(九)使用shader创建鱼的投影
- mongodb 分组聚合_MongoDB学习笔记整理,赶紧收藏起来吧
- 19.SimLogin_case01
- java 中异步消息通知,ActivityMQ的基本使用
- 如何正确地将Blender模型导入进Unity3D
- 巨头特斯拉的进击之路
- CSS3 经典教程系列:CSS3 线性渐变(linear-gradient)
- 用python画爱心写一句话_python中用turtle画爱心表白
- JS实现动画特效2(缓动函数封装、导航栏筋斗云效果)
- 手算梯度下降法,详解神经网络迭代训练过程
- 企业需要k2来解放孤岛危机
- html怎么安装整合包,上古卷轴5无心10.0整合包怎么安装_上古卷轴5无心10.0整合包安装教程_飞翔教程...