导读kafka是一个分布式，分区的，多副本的，多订阅者的消息发布订阅系统，可以用于搜索日志，监控日志，访问日志等。今天小编来领大家一起来学习一下Kafka消费与心跳机制。Kafka提供了非常简单的消费API，使用者只需初始化Kafka的Broker Se

MQ框架非常之多，比较流行的有Kafka、ZeroMq、RabbitMq、ActiveMq。这几种MQ到底应该选择哪个？要根据自己项目的业务场景和需求。下面我列出这些MQ之间的对比数据和资料。其中包括持久化消息和瞬时消息的测试。整个过程共产生1百万条1K的

本文使用Burrow和Telegraf搭建Kafka的监控体系。然后，简单介绍一下其他的，比如Kafka Manager，Kafka Eagle，Confluent Control Center等。Burrow依赖路径使用Burrow拉取kafka的监控信

<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.10&am

一直以来都想写一点关于kafka consumer的东西，特别是关于新版consumer的中文资料很少。最近Kafka社区邮件组已经在讨论是否应该正式使用新版本consumer替换老版本，笔者也觉得时机成熟了，于是写下这篇文章讨论并总结一下新版本consu

# 指定分区处理类。# 是否压缩，默认0表示不压缩，1表示用gzip压缩，2表示用snappy压缩。压缩后消息中会有头来指明消息压缩类型，故在消费者端消息解压是透明的无需指定。# 2: 当所有的follower都同步消息成功后发送ack.异步可以提高发送吞

物联网+大数据+机器学习将会是以后的趋势，这里介绍一篇这方面的文章包含源码。混合机器学习基础架构构建了一个场景，利用Apache Kafka作为可扩展的中枢神经系统。本文重点介绍内部部署。创建了一个带有KSQL UDF的Github项目，用于传感器分析。它

目前来说，kafka的日志中记录的内容比较多，具体的存储内容见这篇博客，写的比较好。下面我们通过kafka启动过程的源码，分析下kafka的日志处理过程。/ start log manager /logManager = createLogManagerl

在过去的几年中，Apache Kafka的功能和覆盖范围已经有了很大的提高。“财富”500强中有三分之一用于生产，其中包括十大全球银行中的七家，十大保险公司中的八家，以及美国十大电信公司中的九家。本文快速浏览卡夫卡提供的核心功能。我将介绍很多示例来帮助您了

事件驱动是一种灵活的系统设计方法，在事件驱动的系统中，当数据发生变化时系统会产生、发布一个对应的事件，其它对这个事件感兴趣的部分会接收到通知，并进行相应的处理。当然，任何事务都有两面性，事件驱动也有其不好的方面。所以当我们决定采用事件驱动实现系统中，一定要

LinkedIn有个三人小组出来创业了—正是当时开发出Apache Kafka实时信息列队技术的团队成员，基于这项技术Jay Kreps带头创立了新公司Confluent，致力于为各行各业的公司提供实时数处理服务解决方案，其他两位成员是Neha Narkh