官网:http://kafka.apache.org/

http://kafka.apache.org/quickstart

环境:ubuntu 16.04

1.安装JDK

2.安装zookeeper,并启动

3.下载解压

wget http://mirrors.hust.edu.cn/apache/kafka/1.1.0/kafka_2.12-1.1.0.tgz

tar -zxvf kafka_2.12-1.1.0.tgz

4.运行kafka server

cd kafka_2.12-1.1.0

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

config/server.properties文件中,指定了连接zookeeper服务地址

5.创建生产者Producer

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

(topic中不能带斜杠/)


6.创建消费者Consumer

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


搭建kafka消息队列服务相关推荐

  1. CentOS7 搭建Kafka消息队列环境,以及Python3操作Kafka Demo

    Kafka适合什么样的场景? 它可以用于两大类别的应用: 构造实时流数据管道,它可以在系统或应用之间可靠地获取数据. (相当于message queue) 构建实时流式应用程序,对这些流数据进行转换或 ...

  2. kafka消息队列应用总结

    kafka官网: Apache Kafka 公司使用阿里云提供的kafka消息队列服务,分别为测试环境与生产环境,部署了多个集群. 使用场景:应用对外提供API接口调用,同时支持kafka增量消息推送 ...

  3. 基于Docker搭建分布式消息队列Kafka

    本文基于Docker搭建一套单节点的Kafka消息队列,Kafka依赖Zookeeper为其管理集群信息,虽然本例不涉及集群,但是该有的组件都还是会有,典型的kafka分布式架构如下图所示.本例搭建的 ...

  4. Kafka消息队列的搭建与基础使用

    一.Kafka消息队列 1.为什么需要消息队列? 解耦 冗余 扩展性 灵活性 & 峰值处理能力 可恢复性 顺序保证 缓冲 异步通信 2.消息队列的模式 1.点对点模式 一对一,消费者主动拉取数 ...

  5. 快速搭建基于beanstalk的php消息队列服务

    本项目实现基于beanstalk的php消息队列服务,包括生产与消费消息案例 一.beanstalk介绍与安装:http://kr.github.io/beanstalkd/ 二.php消息队列处理, ...

  6. 19 kafka消息队列

    文章目录 19 kafka消息队列 一.kafka介绍 1.消息队列基本介绍 2.常用的消息队列介绍 3.消息队列的应用场景 4.消息队列的两种模式 5.kafka的基本介绍 6.kafka的架构介绍 ...

  7. java 结合redis队列_在 Java 中使用 redis 的消息队列服务

    前言 关于 redis 我们前面已经讨论过了缓存.分布式锁.分布式唯一标识.LBS服务的用法,这里我们来谈谈利用 redis 来实现一个消息服务. 典型的消息服务是一个生产者和消费者模式的服务.一般是 ...

  8. 使用kafka消息队列中间件实现跨进程,跨服务器的高并发消息通讯

    作者 | 陈屹       责编 | 欧阳姝黎 近来工作上接收到一项任务,实现c++后台服务器程序,要求它能承载千万级别的DAU读写请求.目前实现千万级高并发海量数据请求的服务器设计在"套路 ...

  9. kafka 消息队列

    kafka 消息队列 kafka 架构原理 大数据时代来临,如果你还不知道Kafka那就真的out了!据统计,有三分之一的世界财富500强企业正在使用Kafka,包括所有TOP10旅游公司,7家TOP ...

最新文章

  1. 2021/11/24 微软亚州研究院游记
  2. python 抓取“煎蛋妹子图”并分页存在本地(普通版和多线程版)
  3. 将RHEL7/centos7系统网卡名称eno16777736改为eth0
  4. Android自定义AlertDialog
  5. 当集合a为空集时a的取值范围_高中数学必修一第一章集合分节练习和章末测试题含答案[1] 2...
  6. 高通modem启动过程_苹果首次承认正自研基带芯片,高通要被抛弃了?
  7. wPython环境安装
  8. 如何使用dos启动mysql数据库_如何使用dos命令启动停止mysql数据库?
  9. PR卡点插件 Premiere自动卡点自动剪辑插件 音乐鼓点节拍插件BeatEdit v1.0.10.2+使用教程
  10. 电脑自带热点,去打不开热点(解决方案)
  11. java 判断条件_Java初学者:条件判断及其语句
  12. 吉吉国王(树形dp)
  13. 华为服务器批量BMC修改密码,华为服务器批量修改bmc地址
  14. 英语六级(包含作文)
  15. 「管理数学基础」1.6 矩阵理论:方阵相似的条件、若当标准形
  16. linux 关机命令总结,Linux关机命令总结
  17. 关于noilinux的一些操作方法
  18. ns-3-model-library wifi 浅析_ns-3wifi部分解析_ns-3网络模拟器wifi部分文档分析_Part1
  19. 【ESP32_8266_WiFi (二)】接入点模式、无线终端模式
  20. Android流畅启动动画,简单设置你的安卓 绝对流畅到爆

热门文章

  1. 关闭谷歌 Chrome 浏览器不再支持 Win7的置顶横条通知
  2. Java-Swing-JTable(DefaultTableModel)
  3. 入手评测 荣耀平板v7pro和荣耀平板v6参数对比 荣耀平板v6 和荣耀平板v7pro的区别
  4. python将图片转换成动漫_如何把照片变成手绘动漫化?
  5. u盘做完启动盘怎么恢复
  6. 每日一题--设计一个呼叫中心系统(Google面试推荐书Cracking the Coding Interview)
  7. 【Blender教程】在Blender中制作森系少女(下)
  8. 育碧2k微软服务器,2K工作室更名-2K Games,育碧,全境封锁2 ——快科技(驱动之家旗下媒体)--科技改变未来...
  9. 【MyBatis-Plus】多租户情况下使用 CONVERT 实现拼音字母时排序报错
  10. (转载)CString,string,char*的综合比较