问答 2023-09-20 来自:开发者社区

Flink CDC有同时包含kafka以及cdc的pom文件啊 我这边一直在报依赖问题?

Flink CDC有同时包含kafka以及cdc的pom文件啊 我这边一直在报依赖问题?

问答 2023-09-13 来自:开发者社区

flink cdc 不需要依赖kafka啊, 即使配置了ha, 不就能恢复了吗?

flink cdc 不需要依赖kafka啊, 即使配置了ha, jobmanager读取checkpoint不就能恢复了吗?

问答 2023-02-21 来自:开发者社区

这个kafka依赖也有,这个报错是什么?

这个kafka依赖也有,这个报错是什么?

文章 2023-01-11 来自:开发者社区

Kafka-Kraft 模式(不依赖Zookeeper)

1. Kafka-Kraft 架构左图为 Kafka 现有架构,元数据在 zookeeper 中,运行时动态选举 controller,由controller 进行 Kafka 集群管理。右图为 kraft 模式架构(实验性),不再依赖 zookeeper 集群,而是用三台 controller 节点代替zookeeper,元数据保存在 controller 中,由 controller 直接进....

Kafka-Kraft 模式(不依赖Zookeeper)
问答 2022-08-17 来自:开发者社区

我看到最新的cdc依赖的kafka版本都是2.7.0的但是将cdc的依赖的引入到项目中之后会变成2.

我看到最新的cdc依赖的kafka版本都是2.7.0的但是将cdc的依赖的引入到项目中之后会变成2.3.0,项目中并没有依赖到kafka,有大佬知道这个问题吗

问答 2022-02-15 来自:开发者社区

spark streaming 和 kafka ,打成jar包后((相关第三方依赖也在里面)),放到集群上总是报StringDecoder 找不到class,但我确定是存在的,就算换成另一种--jars提交了相关kafka的依赖包,spark-submit执行后不是TopicMetadataRequest类找不到就是StringDecoder找不到,kafka是0.8.2.1,spark'是1.6.0-cdh5.8.0的,大家遇到过这种问题吗

spark streaming 和 kafka ,打成jar包后((相关第三方依赖也在里面)),放到集群上总是报StringDecoder 找不到class,但我确定是存在的,就算换成另一种--jars提交了相关kafka的依赖包,spark-submit执行后不是TopicMetadataRequest类找不到就是StringDecoder找不到,kafka是0.8.2.1,spark'是1.....

文章 2022-02-12 来自:开发者社区

kafka去除zookeeper依赖

Kafka 2.8.0新版发布,移除了对Zookeeper的依赖,通过KRaft进行自己的集群管理,一听到KRaft,我们就想到了Raft协议。Raft协议是当今最流行的分布式协调算法,Etcd、Consul等系统的基础,就来自于此。1. 如何开始KRaft?# ./bin/kafka-storage.sh random-uuid # ./bin/kafka-storage.sh format ....

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

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等