写个demo 练练手 ， 结论: 思维必须成流式 ，不要以数据库的方式去看待流式聚合 ， 流式的聚合，在time ...[作者空间]

实际 子拓扑 有5个 。 共起来20个任务 每个任务对应一个或多个分片 , Sub-topology: ...[作者空间]

6.1 概述6.1.1 Kafka StreamsKafka Streams。Apache Kafka开源项目的一...[作者空间]

通过自定义实现KafkaClientSupplier接口实现从一个kafka集群读取数据，再写入到另一个kafka...[作者空间]

流 某一个时间点开始，产生数据，并延伸到时间尽头，无法预测下一条数据何时到达。比如鼠标点击事件clickEvent...[作者空间]

目录 只发送，不关心是否成功 同步发送 异步发送 序列化方法 消费者代码 代码运行前提 完整代码 Kafka提供了...[作者空间]

0. 是什么 Kafka Streams 是一个流式处理框架，功能类似于 storm、flink。 Jay Kre...[作者空间]

同为流处理技术，Kafka Streams的API和更为人所熟知的Spark Streaming在很多方面有不少相...[作者空间]

KStream和KTable是Kafka Streams里内建的两个最重要的抽象，分别对应数据流和数据库。Kafk...[作者空间]

WordCount WordCount 堪称大数据界的HelloWorld，相信不管是Hadoop还是Spark等...[作者空间]

原文：Real-time Financial Alerts at Rabobank with Apache Kaf...[作者空间]

转自: Java 8 中的 Streams API 详解 为什么需要 Stream Stream 作为 Java ...[作者空间]

序 本文简单介绍一下kafka streams的join操作 join A join operation merg...[作者空间]

序 kafka呢其实正道不是消息队列，本质是日志存储系统，而stream processing是其最近大力推广的特...[作者空间]

kafka stream入门1 最近本人在单位经常有对于大量心跳数据进行汇总计算，然后更加计算汇总出不同种类的中间...[作者空间]

由于目前作者使用的 kafka 版本是 0.10.1，因此本章翻译以0.10.1版本的官方文档进行翻译，官方原文地...[作者空间]