1 下载地址 http://www.kafkatool.com/download.html 2 下载dmg包,选择对应版本,我的kafka是2.1的版本,所以选择了Kafka Tool 2.0.4 3 安装过程,一路下一步 4 配置kafka集群,注意本机的hostname配置,根据个人机器情况配置 ...
分类:
系统相关 时间:
2019-03-12 10:36:00
阅读次数:
1061
简单的介绍下基于JMS的消息传送 Java消息队列JMS整体设计结构 基本要素:生产者(producer),消费者(consumere),消息服务(broker) 交互模型: JMS两种消息传送模式 点对点(Point-to-Point):专门用于使用队列Queue传送消息; 发布/订阅(Publi ...
分类:
其他好文 时间:
2019-03-06 19:14:49
阅读次数:
157
摘自:https://www.cnblogs.com/qingyunzong/p/9004703.html 一、高可用的由来 1.1 为何需要Replication 在Kafka在0.8以前的版本中,是没有Replication的,一旦某一个Broker宕机,则其上所有的Partition数据都不可 ...
分类:
其他好文 时间:
2019-03-05 23:03:14
阅读次数:
225
数据库分离(备份)后,附加(还原)回到数据库,然后在程序中打开调用数据库的页面,出现如下问题:“未启用当前数据库的 SQL Server Service Broker,因此查询通知不受支持。如果希望使用通知,请为此数据库启用 Service Broker ”。 解决方案:(可直接执行第二步)在使用的 ...
分类:
数据库 时间:
2019-03-05 18:24:32
阅读次数:
200
使用ranger对kafka进行鉴权测试环境:ranger-kafka-plugin为0.6.3版本,kafka版本为kafka_2.10-0.10.1.1,且kafka broker为一个节点。一、Ranger对kafka进行权限控制,前提需要kafka开启kerberos认证(注意:若kafka ...
分类:
其他好文 时间:
2019-03-05 11:37:51
阅读次数:
852
Broker:英语有代理的意思,在activemq中,Broker就相当于一个Activemq实例。 1. 命令行启动实例: 1.activemq start使用默认的activemq.xml启动 启动后访问后台: 2.activemq start xbean:file:../conf/active ...
分类:
其他好文 时间:
2019-03-03 09:34:13
阅读次数:
139
概述 ActiveMQ是由Apache出品的,一款最流行的,能力强劲的开源消息总线。ActiveMQ是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,它非常快速,支持多种语言的客户端和协议,而且可以非常容易的嵌入到企业的 ...
分类:
其他好文 时间:
2019-02-27 17:56:22
阅读次数:
228
一:什么是Celery 一:Celery介绍 Celery是一个简单、灵活且可靠的,处理大量消息的分布式系统 专注于实时处理的异步任务队列 同时也支持任务调度 架构详解: Celery的架构由三部分组成,消息中间件(message broker),任务执行单元(worker)和任务执行结果存储(ta ...
分类:
其他好文 时间:
2019-02-22 21:26:18
阅读次数:
162
Celery - 一个懂得 异步任务 , 定时任务 , 周期任务 的芹菜 1.什么是Celery?Celery 是芹菜Celery 是基于Python实现的模块, 用于执行异步定时周期任务的其结构的组成是由 1.用户任务 app 2.管道 broker 用于存储任务 官方推荐 redis rabbi ...
分类:
其他好文 时间:
2019-02-19 21:16:37
阅读次数:
208
一.什么是Celery? 中文名翻译为芹菜,是flask中处理异步定时周期任务的第三方组件 二.基本结构 1.需要跑的任务代码app 2.用管道broker与用于存储任务(就是个缓存) 工具一般用redis 或者用rabbitMQ(兔子) 3.执行任务的人worker 简单实例 首先建立三个文件分别 ...
分类:
其他好文 时间:
2019-02-18 11:29:24
阅读次数:
287