Kafka

首页 标签 Kafka
# Kafka #
关注
9975内容
Ambari 功能简介
背景 最近在做关于Hadoop集群的可视化部署相关的调研,发现了Ambari这个有趣的东西,在使用的过程中,整理了一部分功能列表,在此分享。
Apache Flink fault tolerance源码剖析(一)
因某些童鞋的建议,从这篇文章开始结合源码谈谈Flink Fault Tolerance相关的话题。上篇官方介绍的翻译是理解这个话题的前提,所以如果你想更深入得了解Flink Fault Tolerance的机制,推荐先读一下前篇文章理解它的实现原理。
实时数据交换平台 - BottledWater-pg with confluent
标签 PostgreSQL , Bottled Water , Kafka , Confluent , IoT 背景 想必大家都在图书馆借过书,小时候有好看的书也会在小伙伴之间传阅。 借书和数据泵有点类似,一份数据通过数据泵实时的分享给订阅者。 例如在IoT的场景中,有流式分析的需求,也有存储历史数据的需求,同时还有数据挖掘的需求,搜索引擎可能也需要同一份数据,还有一些业务可能也要用
Apache Druid接入Kafka实时流数据
一.任务配置文件 使用类型为kafka { "type": "kafka", "dataSchema": { "dimensionsSpec": {... ...}, "transformSpec":{.
kafka 的有序与无序
同时创建kafka生产者produce,kafka消费者consumer,其中我们的topic创建了3个分区,  生产者发送几条数据,使用命令查看消费。 可以看到刚刚生产的这几条数据,当我退出消费命令,重新使用消费者命令来消费数据时,看一下数据 这时候看到的数据时无序的,总结一点 单个分区:有序 全局分区:无序 1 4肯定是同一个分区的数据,如何保证生产环境下,全局有序呢,先说下必须要保持有序的需求情况, 有一张students表,对表操作的消息发送到kafka中,但是操控表有增加有删除的时候,必须增加先执行 完,才去删除,如果先执行删除了,在insert增加就是错误的了。
免费试用