问答 2022-10-08 来自:开发者社区

shake中mongoshake 现在支持连接开启鉴权的kafka 吗?

shake中mongoshake 现在支持连接开启鉴权的kafka 吗?

问答 2022-09-28 来自:开发者社区

flink on yarn 认证 kerberos 连接kafka这个资料谁有吗?

flink on yarn 认证 kerberos 连接kafka这个资料谁有吗?

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

有没有办法删除 debezium 的 在kafka上存储的history重新建立这个同名连接?

有没有办法尚删除 debezium 的 在kafka上存储的history主题后,重新建立这个同名的连接,不报错 io.debezium.DebeziumException: The db history topic is missing. You may attempt to recover it by reconfiguring the connector to SCHEM...

问答 2022-09-01 来自:开发者社区

求助大佬们,flink1.14.5连接kafka,一直报这个错误,请问有遇到过吗?

求助大佬们,flink1.14.5连接kafka,一直报这个错误,请问有遇到过吗? org.apache.flink.util.FlinkRuntimeException: Failed to send data to Kafka xxx_1-0@-1 with FlinkKafkaInternalProducer{transactionalId='kafka-sink-0-1204', inT....

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

大佬有遇见过这个错误的吗?连接kerberos的kafka的时候失败

org.apache.kafka.common.errors.SaslAuthenticationException: An error: (java.security.PrivilegedActionException: javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: No vali....

问答 2022-08-04 来自:开发者社区

大佬们,我flink 采用 upsert-kafka作为连接器建表(t1),数据中具有相同更新时间的

大佬们,我flink 采用 upsert-kafka作为连接器建表(t1),数据中具有相同更新时间的多条数据,查询t1表,数据取的是哪条呢

问答 2022-07-30 来自:开发者社区

请问kafka 连接器创建kafka source表时配置参数'topic-pattern'='(e

请问kafka 连接器创建kafka source表时配置参数'topic-pattern'='(empty)|(student)',如果正则中的部分topic未创建,此时job运行后,后续创建的topic会被消费吗?或者有什么办法能在任务运行后,将后续创建的,同时能被正则匹配的topic,也被运行中的任务消费吗。

问答 2022-07-28 来自:开发者社区

dataworks数据源怎么配线下连接串模式的kafka?

dataworks数据源怎么配线下连接串模式的kafka?

问答 2022-07-22 来自:开发者社区

有没有大佬帮我看下flink sql连接kafka认证kerberos的参数配置是否有误

有没有大佬帮我看下flink sql连接kafka认证kerberos的参数配置是否有误

问答 2022-07-01 来自:开发者社区

请问,我这边设置了upsert-kafka 连接器,,为啥读取出来的 主键 没有更新呢,偏移量还是增

请问,我这边设置了upsert-kafka 连接器,,为啥读取出来的 主键 没有更新呢,偏移量还是增长呢,读取的条数还是那么多?

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

产品推荐

云消息队列

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

+关注