函数计算 yaml里面配置了kafka触发器每次部署都会重新退出再订阅,请问有办法可以不重新订阅吗?

函数计算 yaml里面配置了kafka触发器每次部署都会重新退出再订阅,kafka触发器启动很慢,请问有办法可以不重新订阅吗?

Flink CDC里为啥我用flink sql从kafka订阅canaljson插入数据删除不了?

Flink CDC里我用flink sql从kafka订阅canaljson插入数据,如果这个数据插入后,重启任务,然后发送canaljson无法删除,不重启可以。

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

Kafka的发布-订阅功能: Java实现与应用场景解析

Kafka的发布-订阅功能: Java实现与应用场景解析Apache Kafka 是一个流行的分布式消息传递系统,广泛用于构建实时数据管道和流应用程序。它以高吞吐量、内置的分区、副本和容错性著称。Kafka 主要提供发布-订阅模式,这里我们将深入探讨 Kafka 的发布-订阅功能,通过一个 Java...

[帮助文档] 如何使用Kafka客户端消费订阅数据

新版数据订阅支持使用0.11版本至2.7版本的Kafka客户端消费订阅数据,DTS为您提供了Kafka客户端Demo,本文将介绍该客户端的使用说明。

[帮助文档] 如何使用Kafka客户端消费订阅数据

新版数据订阅支持使用0.11版本至2.7版本的Kafka客户端消费订阅数据,DTS为您提供了Kafka客户端Demo,本文将介绍该客户端的使用说明。

请问使用dts数据订阅产品的时候,为什么有时候会忽然和dts的kafka集群断连,造成数据延时

请问使用dts数据订阅产品的时候,为什么有时候会忽然和dts的kafka集群断连,造成数据延时

Zookeeper搭载kafka消息发布和订阅

一、Zookeeper简介ZooKeeper 是一个开源的分布式协调服务,由雅虎创建,是 Google Chubby 的开源实现。分布式应用程序可以基于 ZooKeeper 实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、配置维护,名字服务、分布式同步、分...

请问一下,flink kafka source设置并行度,因为有多个topic需要订阅,应该怎么设置

请问一下,flink kafka source设置并行度,因为有多个topic需要订阅,应该怎么设置比较合理呢,是设置成topic数量,还是topic*分区数比较合理?

大佬们好, 我们公司之前业务场景一直是使用canal来做binlog的订阅发送到Kafka和Rock

大佬们好, 我们公司之前业务场景一直是使用canal来做binlog的订阅发送到Kafka和RocketMQ,属于重度依赖binlog订阅, 目前遇到的一个问题是同一个数据库的订阅任务太多,导致改数据库的slave数量非常多, DBA在做表的无锁变更时会产生非常多的流量,有可能会导致ddl变更失败,...

Springboot最简单的实战介绍 整合kafka-生产者与消费者(消息推送与订阅获取)

Springboot最简单的实战介绍 整合kafka-生产者与消费者(消息推送与订阅获取)

我们开始整合:首先,先往pom.xml文件添加Kafka的依赖,<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifac...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载

云消息队列 Kafka 版订阅相关内容