Kafka Streams开发入门(1)
背景 最近发现Confluent公司在官网上发布了Kafka Streams教程，共有10节课，每节课给出了Kafka Streams的一个功能介绍。这个系列教程对于我们了解Kafka Streams还是很有帮助的。为什么要了解Kafka Streams？其实我一直觉得国内对于Flink有点 ...
原文：Kafka .net 开发入门
Kafka安装 首先我们需要在windows服务器上安装kafka以及zookeeper,有关zookeeper的介绍将会在后续进行讲解。 在网上可以找到相应的安装方式，我采用的是腾讯云服务器，借鉴的是https: www.cnblogs.com lnice p .html 根据上面博客安装完成后，我们在kafka中新建了一个名叫test的Topic,并新建了一个生产者和一个消费者。 注：控制台 ...
2019-07-22 21:02 0 1077 推荐指数：
相关推荐
Kafka Streams开发入门(7)
1. 背景 上一篇介绍了如何利用Kafka Streams找出并过滤掉实时流中那些重复的消息。本篇将介绍如何对消息中特定数据进行求和汇总。 2. 功能演示说明 假设我们要执行汇总求和的事件格式如下： {"title":"Die Hard","sale_ts":"2019-07-18T10 ...
Kafka Streams开发入门(9)
1. 背景 上一篇介绍了如何利用Kafka Streams实时统计某年最卖座和最不卖座的电影票房。主要的方法是通过Streams提供的aggregate方法实现了max/min算子。今天我为大家带来时间窗口函数的使用方法。在Kafka Streams中，时间窗口有三类：固定时间窗口 ...
Kafka Streams开发入门(2)
背景 上一篇我们介绍了Kafka Streams中的消息转换操作map，今天我们给出另一个经典的转换操作filter的用法。依然是结合一个具体的实例展开介绍。 演示功能说明 本篇演示filter用法，即根据给定的过滤条件或逻辑实时对每条消息进行过滤处理。今天使用的输入topic消息格式 ...
Kafka Streams开发入门(10)
1. 背景 上一篇介绍了Kafka Streams的时间窗口以及Tumbling Window的实例。这一篇我们利用Kafka Streams中的KTable概念来实时计算一组电影的平均分数。 2. 功能演示说明 这篇文章中我们会创建一个Kafka topic来表示电影打分事件，然后我们编写 ...
Kafka.net使用编程入门
最近研究分布式消息队列，分享下！ 首先zookeeper 和 kafka 压缩包 解压 并配置好！ 我本机zookeeper环境配置如下: D:\Worksoftware\ApacheZookeeper3\conf\zoo.cfg 以下是kafka的配置 D ...
Kafka.net使用编程入门(二)
1.首先创建一个Topic，命令如下: 2.创建两个控制台程序: 3.KafkaProducer程序: 4.KafkaConsumer程序: ...
Kafka.net使用编程入门(四)
新建一个cmd窗口，zkServer命令启动zookeeper 打开另一个cmd窗口,输入: kafka 删除topic 提示marked for deletion 并没有真正删除，如果要真正删除 在每一台机器中的kafka_2.10/config/server.properties ...