一.要使用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基础简单应用相关推荐

  1. graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二)

    graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylo ...

  2. Kafka单机部署学习演示案例

    Kafka 单机部署演示 前置准备 虚拟机配置: 内存:3G 处理器:1 核数:1 (一)kafka 安装 去kafka官网下载稳定版本到Linux服务器中进行解压安装.下载链接,我这里使用的是2.7 ...

  3. KAFKA 最新版 单机安装、配置、部署(linux环境)

    文章目录 一.基础软件下载 1. JDK 2. KAFKA 3. ZOOKEEPER 二.zookeeper配置启动 2.1. 解压 2.2. 配置环境变量 2.3. 刷新环境变量 2.4. 配置文件 ...

  4. 1、nifi-1.9.2介绍、单机部署及简单验证

    Apache NiFi系列文章 1.nifi-1.9.2介绍.单机部署及简单验证 2.NIFI应用示例-GetFile和PutFile应用 3.NIFI处理器介绍.FlowFlie常见属性.模板介绍和 ...

  5. graylog+kafka+zookeeper(单机测试及源码),graylog收集kafka(脚本创建发布订阅方式)存储的消息(四)

    graylog+kafka+zookeeper(单机测试及源码),graylog收集kafka(脚本创建发布订阅方式)存储的消息(四) 问题背景 graylog+kafka+zookeeper(单机测 ...

  6. graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三)

    graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylog组件部署 ...

  7. FastDFS单机部署安装

    FastDFS单机部署安装 文章目录 FastDFS单机部署安装 前言 1:服务器规划 2:安装包 3:所有tracker和storage节点都执行如下操作 3.1:安装所需的依赖包 3.2:安装li ...

  8. Kafka入门(一) 概述、部署与API的简单使用

    Kafka入门(一) 概述.部署与API的简单使用 MQ 传统架构的问题 MQ简介 MQ的优缺点 优点 缺点 同步与异步 P2P模式 订阅发布模式 Kafka概述 简介 特点 名称解释 Broker ...

  9. java+鼠标滑过变小手_Kafka单机部署

    一.kafka介绍及原理 kafka是由Apache软件基金会发布的一个开源流处理平台,由Scala和Java编写.它是一种高吞吐量的分布式发布的订阅消息系统,它可以处理消费者规模的网站中的所有动作流 ...

最新文章

  1. 别再说学不会:超棒的Numpy可视化学习教程来了
  2. 谷歌Jeff Dean团队提出利用深度学习对「电子健康记录」数据进行分析,可提高医疗诊断预测的准确性
  3. MySQL的主从复制主从同步
  4. linux使用qemu教程,Linux:使用 QEMU 测试 U-BOOT的步骤
  5. 第三次学JAVA再学不好就吃翔(part32)--方法重写
  6. 北理计算机教案,北理工版三年级信息技术教案重点.docx
  7. 高阶函数(Higher-order function)
  8. 比特斯拉酒瓶更贵!小鹏汽车推出“金属麻将”:1999元
  9. (转)cocos2d-x学习笔记(九)使用shader创建鱼的投影
  10. mongodb 分组聚合_MongoDB学习笔记整理,赶紧收藏起来吧
  11. 19.SimLogin_case01
  12. java 中异步消息通知,ActivityMQ的基本使用
  13. 如何正确地将Blender模型导入进Unity3D
  14. 巨头特斯拉的进击之路
  15. CSS3 经典教程系列:CSS3 线性渐变(linear-gradient)
  16. 用python画爱心写一句话_python中用turtle画爱心表白
  17. JS实现动画特效2(缓动函数封装、导航栏筋斗云效果)
  18. 手算梯度下降法,详解神经网络迭代训练过程
  19. 企业需要k2来解放孤岛危机
  20. html怎么安装整合包,上古卷轴5无心10.0整合包怎么安装_上古卷轴5无心10.0整合包安装教程_飞翔教程...

热门文章

  1. Linux的基本指令(图文并茂,一目了然)
  2. springboot 给图片加二维码
  3. python下划线怎么输入_python下划线怎么打出来
  4. 【ManageEngine卓豪】移动终端管理解决方案,助力中州航空产业数字化转型
  5. 自己动手删除时常来袭的 木马、病毒
  6. 当你在浏览器输入baidu.com并敲下回车发生了什么
  7. 浅谈:什么是API接口
  8. 【Luogu】B2119 删除单词后缀
  9. CS231n 第一讲 线性分类:SVM,Softmax
  10. coroutine 携程与定时一起混用