云消息队列 Kafka 版版本的相关内容

返回频道云消息队列 Kafka 版版本

阿里云文档 2023-09-03

为什么升级实例版本时间过长_云消息队列 Kafka 版(Kafka)

升级实例版本时花费的时间过长有如下可能：升级资源所需的ECS节点、云盘等资源库存补充不及时，导致升级过慢。短时间内，升级任务较多，导致升级调度资源紧张。您长时间未进行小版本升级，升级内容较多，导致升级过慢。

问答 2023-06-20 来自：开发者社区

Flink1.17.1版本，连接Kafka，总是报告错误，这个问题怎么解决呀？在Flink1.16.

Flink1.17.1版本，连接Kafka，总是报告错误，这个问题怎么解决呀？在Flink1.16.1中，可以成功。但是不知道是在哪个包里面。新建一个工程成功了，我一会儿仔细检查一下，是什么冲突了。终于找到问题所在，这里不能用kafka。

问答 2023-06-17 来自：开发者社区

我现在用的datawork版本数据源配置里只有kafka，但是我们用的pulsar，我配置了？

我现在用的datawork版本数据源配置里只有kafka，但是我们用的pulsar，我配置了pulsar集群地址，但是连接不上，问下支持连pulsar吗？

问答 2023-06-04 来自：开发者社区

Flink CDC适配了很多版本，kafka 各种错？这个怎么破？版本是这样的？怎么适配不会报错

Flink CDC适配了很多版本，kafka 各种错？这个怎么破？link SQL> insert into sink_user select * from source_user_kafka; [ERROR] Could not execute SQL statement. Reason: java.lang.NoSuchMethodError: org.apache.flink.tabl...

问答 2023-05-08 来自：开发者社区

cana-kafak1.1.0版本，搭建kafka消费客户端，怎么对ROWDATA类型的storeV

2018-10-31 15:49:04.318 [Thread-1] INFO c.a.o.canal.client.running.kafka.CanalKafkaClientExample - Message[id=12,entries=[header { version: 1 logfileName: "mysql-bin.000002" logfileOffset: 1206761 se....

问答 2023-05-08 来自：开发者社区

canal.kafka 1.1.0版本 canal.instance.filter.regex 无法

设置了canal.instance.filter.regex= dm.orders 。但是别的表还是订阅了。原提问者GitHub用户whiney

问答 2023-05-08 来自：开发者社区

1.1.1 版本Kafka 不通

与没有诊断工具？ $cat conf/mq.yml servers: 127.0.0.1:9092 #for rocketmq: means the nameserver retries: 0 batchSize: 16384 lingerMs: 1 bufferMemory: 33554432 Canal的batch size, 默认50K, 由于kafka最大消息体限制请勿超过1M(900K....

问答 2023-05-08 来自：开发者社区

1.1.1版本kafka取出的json数据缺少data字段什么原因

1.1.1版本 kafka 取json数据，本地测试有data字段data:[{name:"abc"}]，canal连接linux上的数据库后就没有data这个字段了什么原因啊是不是只有delete和update语句才有 data字段，为什么insert没有呢 linux mysql为5.6版本 win为5.5 原提问者GitHub用户CodeLulu318

问答 2023-05-08 来自：开发者社区

1.1.1版本，kafka模式,flatMessage为false时,filter.black设置无

配置如下： /conf/example/instance.properties 配置 canal.instance.filter.black.regex=quartz_db.* /conf/mq.yml 配置 flatMessage: false 现象： kafka模式,filter.black设置了过滤quartz_db所有的表: 设置flatMessage为false时, 当quartz_d....

问答 2023-05-08 来自：开发者社区

1.1.1版本kafka设置分区数量partitionsNum没用

请问是否要将 flatMessage 设置为 true 才会生效？ servers: localhost:9092 retries: 1 batchSize: 16384 lingerMs: 1 bufferMemory: 33554432 Canal的batch size, 默认50K, 由于kafka最大消息体限制请勿超过1M(900K以下) canalBatchSize: 50 Canal....