1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. K>
  5. kafka更新offset api

当前主题:kafka更新offset api

kafka更新offset api相关的博客

查看更多 写博客

从未如此简单:10分钟带你逆袭Kafka!

云栖号资讯:【点击查看更多行业资讯】 在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! 【编者的话】Apache Kafka 是一个快速、可扩展的、高吞吐的、可容错的分布式“发布-订阅”消息系统, 使用 Scala 与 Java 语言编写,能够

阅读全文

Flink 1.11 SQL 使用攻略

作者 | 李劲松,Apache Flink Committer,阿里巴巴技术专家 7 月 6 日,Apache Flink 1.11 正式发布。从 3 月初进行功能规划到 7 月初正式发版,1.11 用将近 4 个月的时间重点优化了 Flink 的易用性问题

阅读全文

Flink 1.11 新特性之 SQL Hive Streaming 简单示例

7月7日,Flink 1.11 版本发布,与 1.10 版本相比,1.11 版本最为显著的一个改进是 Hive Integration 显著增强,也就是真正意义上实现了基于 Hive 的流批一体。 本文用简单的本地示例来体验 Hive Streaming 的

阅读全文

完美避坑!记一次 Elasticsearch 集群迁移架构实战

云栖号资讯:【点击查看更多行业资讯】 在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! 前言 Elastic 自身设计了集群分片的负载平衡机制,当有新数据节点加入集群或者离开集群,集群会自动平衡分片的负载分布。 需求背景 公司原有大数据平台基于

阅读全文

spark-streaming-kafka-0-8 官网讲解

spark-streaming-kafka-0-8 Note: Kafka 0.8 support is deprecated as of Spark 2.3.0. 0.8在spark2.3中被标为过时的,但是没关系,还能用 描述两种接收数据的方式recei

阅读全文

Flink 完美搭档:数据存储层上的 Pravega

作者 | 滕昱 DellEMC 研发总监整理 | 赵海凯 DellEMC 实习生 本文将从大数据架构变迁历史,Pravega 简介,Pravega 进阶特性以及车联网使用场景这四个方面介绍 Pravega,重点介绍 DellEMC 为何要研发 Pravega

阅读全文

Streaming SQL在贝壳的演进之路

Streaming SQL在贝壳的演进之路 原文发自公司对外公众号,作者笔名顾渊离,本人,转载请注明出处 背景 实时计算平台是贝壳内部统一承接实时需求和管理实时任务的平台,支持了公司埋点、商机、交易、商业化等若干部门的业务,目前总共运行了570多的实时计算任

阅读全文

Flink kafka source & sink 源码解析

Flink kafka source & sink 源码解析 原创 吴鹏 Flink 中文社区 4天前 摘要:本文基于 Flink 1.9.0 和 Kafka 2.3 版本,对 Flink Kafka source 和 sink 端的源码进行解析,主要内容分

阅读全文