安装

在mac上可以使用brew install kafka进行kafka的安装,在安装kafka时,会自动检测有无zookpeer,如果没有的话也会安装一个。

启动kafka

启动kafka,首先要确保启动zookpeer.

进入kafka安装目录的bin目录下执行 ./zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &(加上&是让他后台运行)

然后在启动kafka:brew services start kafka(此时可以任意路径下)

kafka启动以后执行kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 你的topic的名字

创建一个话题topic

这时可以使用指令:kafka-topics --list --zookeeper localhost:2181查看拥有的topic有哪些。

然后接下来创建一个生产者向该话题传入数据:

kafka-console-producer --broker-list localhost:9092 --topic 话题名字

如图所示,出现>就可以输入数据了。

注意!!!!

在不修改配置的情况下,原始的参数为zookpeer的地址端口是:localhost:2181

kafka服务器的地址是:localhost:9092

然后我们就可以在程序中对kafka消费者进行配置,接受信息:

链接:https://www.jianshu.com/p/dd2578d47ff6

kafka 启动_Kafka的安装与启动相关推荐

  1. kafka自带的zk启动_kafka单机安装和启动

    1.下载并解压到/usr/local/src目录下 2.运行kafka需要使用Zookeeper,先启动Zookeeper,如果没有Zookeeper,可以使用kafka自带打包和配置好的Zookee ...

  2. postgis启动_postgresql的安装和启动方法

    官方文档 二进制安装和启动:https://www.postgresql.org/download/linux/redhat/ 源码安装和启动: https://www.postgresql.org/ ...

  3. postgis启动_PostgreSQL的安装和启动方法大全

    官方文档 二进制安装和启动: https://www.postgresql.org/download/linux/redhat/ 源码安装和启动: https://www.postgresql.org ...

  4. linux使用权限模式启动mongodb,Linux安装MongoDB启动及常见问题解决

    MongoDB安装过程以及问题记录 一.MongoDB安装 下载MongoDB 官方地址: 可能需要注册一下我这里是Centos7系统所以选择的是RHEL7.0的TGZ,其他系统自行选择 如果不想注册 ...

  5. docker开机启动失败_docker安装后启动不了 解决方法

    第一种情况: 可能是你的selinux没有disabled,导致了守护docker的deamon进程启动不了 查看系统日志如果发现下列信息: May 7 12:34:14 localhost dock ...

  6. oFono安装和启动

    安装和启动oFono 1. git clone git://git.kernel.org/pub/scm/network/ofono/ofono.git 2. cd ofono 3. ./bootst ...

  7. 利用INF安装服务启动 及 浅析瑞星行为检测、360主动防御

    序 2010年,反病毒(AntiVirus)与反-反病毒(Anti-AntiVirus)不论是从技术的深度.涉及的方方面面,又上升了一个层次. 行为防御.云安全技术等一些新技术不断的加入反病毒的行列, ...

  8. kafka启动_Kafka安装部署——单节点

    1.1 Kafka的单节点部署 在实际的工作中,经常使用Kafka作为消息队列,然而并不是每一种业务场景都需要集群版的Kafka,有时单节点的Kafka就能满足了业务的需求.以下就是单节点kafka的 ...

  9. Apache Kafka(二)- Kakfa 安装与启动

    安装并启动Kafka 1.下载最新版Kafka(当前为kafka_2.12-2.3.0)并解压: > wget http://mirror.bit.edu.cn/apache/kafka/2.3 ...

最新文章

  1. Linux的判断命令
  2. 自然语言处理NLP之自然语言生成、文本相似性、看图说话、说话生图、语音合成、自然语言可视化
  3. 万亿新基建,AI“芯”机遇在哪?| CCF-GAIR 2020
  4. Spring MVC + Hibernate JPA + Bootstrap 搭建的博客系统
  5. 大话设计模式(七 工厂不好用了?)
  6. 深入理解RocketMQ:Consumer消费消息原理
  7. python替代php,Python架构的PHP替代方案
  8. bash命令行中带通配符参数何时展开??
  9. 信息学奥赛一本通 1084:幂的末尾 | OpenJudge NOI 小学奥数 7833
  10. Promise 源码:静态方法
  11. Java-类型转换,String转Object和Object转String
  12. 软件工程网络15个人作业3——案例分析
  13. Flex之使用DragManager实现对象拖动
  14. jquery ajax get 数组参数
  15. 以组播流方式替换运营商IPTV直播频道
  16. [转载]下载网页中的ts视频文件
  17. HealthKit框架简介
  18. 山西大同大学计算机考试打印准考证
  19. IE7IE8兼容性设置_服务器端设定
  20. html 爬数据,简单爬取html页面的表格中的数据

热门文章

  1. 【数理知识】方程一阶二阶及常用词语含义
  2. 2.2 清除标注错误的数据-深度学习第三课《结构化机器学习项目》-Stanford吴恩达教授
  3. 梯度下降法Gradient Descent深度学习 机器学习
  4. Android 4.0 Notification
  5. 【笔记】windows10安装linux(ubuntu)双系统教程(可能是现今最简单方法)
  6. 硬件三人行-开关电源学习笔记-1
  7. 20051008:看了AppleSeed,领悟到了一个道理:
  8. 我理解的javascript事件循环(一)
  9. Java多线程生产者消费者调度实现
  10. Windows Server2012 搭建域错误“本地Administraor账户不需要密码”