云消息队列 Kafka 版

Flink1.14.4版本消费kafka数据，能外部保存偏移量并维护吗？ 以下为热心网友提供的参考意见 是的，Flink 1.14.4版本支持外部保存Kafka消费偏移量并维护。 …

Flink1.10 kafka0.10运行一段时间后，我把kafka停了，但是flink没有失败，一直在报broker可能不存在的警告，怎么解决呢？我没有配置重启策略，我希望任务在…

Flink中kafkaSink 使用精准一次性语意 为啥恢复任务的时候初始化的时间很长 会导致 ck 失败？ 以下为热心网友提供的参考意见 Flink中kafkaSink使用精准一…

Flink为什么不生效啊？未提交的数据仍然能被消费到kafkaSource 配置了isolation.level=read_committed 以下为热心网友提供的参考意见 Fli…

Flink中kafka 的精准一次 sink 如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了 我这批数据会丢失吗？ 以下为热心网友提供的参考意见 如果你配置了最大连续…

Flink中kafka总共有16266条数据, 但是消费到6144就停止并报这两条日志了？ 以下为热心网友提供的参考意见 从你给出的日志来看，问题是关于Kafka消费者未能获取足够…

flinkcdc能接kafka开了权限认证吗？kafka开了sasl权限认证 以下为热心网友提供的参考意见 可以的，Flink CDC能够接入开启了SASL权限认证的Kafka。在…

flinkcdc能接kafka开了权限认证吗？ 以下为热心网友提供的参考意见 Flink CDC 可以接入开启了权限认证的 Kafka。在接入过程中，需要进行以下步骤：首先，如果您…

我在使用flink kafka连接器的时候，遇到报错问题，没有分析思路，请各位大佬指教一下报错如下图：kafka集成了kerberos，flink是 on yarn模式，与kafk…

在数据传输DTS中，我们服务现在出现了问题，消息一直在重复消费，这是我查看到的异常信息。 完整的日志为： 2023-12-25 14:49:19.525 INFO 1 &#8212…

DataWorks中 kafka 数据源同步到mc , 任务一直在执行中， 选择的同步是5分钟。这种一般是什么问题呢？ 以下为热心网友提供的参考意见 在阿里云DataWorks中，…

Flink这个问题怎么解决？在创建FlinkSQL中创建表的时候报这个错，在Kafka中没有创建这个Topic的时候报异常提示’kafkacatalog’中…