# 云消息队列 Kafka 版 #
0
关注
9995内容
|
kafka 0.11x 启动30秒后自动停止，报【另一个程序正在使用此文件，进程无法访问】
环境：kafka_2.11-1.1.0，win7_64，java8
现象：
启动30秒后自动停止，报【另一个程序正在使用此文件，进程无法访问】
[2018-06-06 14:32:46,784] INFO [Log partition=myTopic-0, dir=D:\kafka_2.
IM系统的MQ消息中间件选型：Kafka还是RabbitMQ？
1、前言
在IM这种讲究高并发、高消息吞吐的互联网场景下，MQ消息中间件是个很重要的基础设施，它在IM系统的服务端架构中担当消息中转、消息削峰、消息交换异步化等等角色，当然MQ消息中间件的作用远不止于此，它的价值不仅仅存在于技术上，更重要的是改变了以往同步处理消息的思路（比如进行IM消息历史存储时，传统的信息系统作法可能是收到一条消息就马上同步存入数据库，这种作法在小并发量的情况下可以很好的工作，但互联网大并发环境下就是灾难）。
如何在E-MapReduce上提交Storm作业处理Kafka数据
本文演示如何在E-MapReduce上部署Storm集群和Kafka集群，并运行Storm作业消费Kafka数据。
|
Kafka+Flink 实现准实时异常检测系统
异常检测可以定义为“基于行动者（人或机器）的行为是否正常作出决策”，这项技术可以应用于非常多的行业中，比如金融场景中做交易检测、贷款检测；工业场景中做生产线预警；安防场景做入侵检测等等。
根据业务要求的不同，流计算在其中扮演着不同的角色：既可以做在线的欺诈检测，也可以做决策后近实时的结果分析、全局预警与规则调整等。
如何构建批流一体数据融合平台的一致性语义保证？
本文根据陈肃老师在 Apache Kafka x Flink Meetup 深圳站的分享整理而成，文章首先将从数据融合角度，谈一下 DataPipeline 对批流一体架构的看法，以及如何设计和使用一个基础框架。其次，数据的一致性是进行数据融合时最基础的问题。
免费试用