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

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

请问canal 支持kafka2.1.0版本吗？

环境信息 canal version 1.1.3 mysql version 5.6 问题描述我在配置了canal.mq.dynamicTopic=...* 时候无法生效，首先我已经打开了自动创建topic（kafka）按照官方说这个意思是根据表名发到各自topic上，然而我现在是配置后，仍然发送到canal.mq.topic 这个默认topic上例子2：...* 匹配所有表，每个表都会发送....

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

1.1.3版本，可以kafka创建topic，但在kafka上没有看到数据

1.1.3版本，可以kafka创建topic，但在kafka上没有看到数据原提问者GitHub用户dankes

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

canal对kafka有版本限制吗？

我们公司的kafka版本是0.9.0（kafka_2.11-0.9.0-kafka-2.0.2-sources.jar），我用canal连接的时候报超时。但是换了高版本的kafka发现是可以连的，canal对kafka有版本限制吗？如果有限制我0.9.0的该用哪种版本的canal呢？ 2020-12-31 09:18:39.388 [pool-6-thread-1] ERROR c.a.o.ca....

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

最新版本的canal-server docker启动的时候，如何通过参数指定kafka机器地址？

最新版本的canal-server docker启动的时候，如何通过参数指定kafka机器地址？配置文件有，但是不能够灵活修改参数，使用 -e kafka.bootstrap.servers=192.168.220.12:9092 这种方式又不生效，而且官方文档也没给出说明原提问者GitHub用户feideyang

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

使用1.1.4版本canal同步数据到Kafka，创建3个实例。重启后其中一个实例会报错 Faile

使用1.1.4版本canal，创建3个实例。重启后其中一个实例会报错 canal instance报错：ERROR com.alibaba.otter.canal.kafka.CanalKafkaProducer - java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: ....

问答 2023-03-15 来自：开发者社区

如果我想用高版本的flink 消费 0.9版本的kafka 有啥好方法没？

问答 2023-02-14 来自：开发者社区

1.15版本的flink往kafka多个topic写消息，是自定义实现KafkaSerializat

1.15版本的flink往kafka多个topic写消息，是自定义实现KafkaSerializationSchema吗？

文章 2023-01-14 来自：开发者社区

如何查看spark与hadoop、kafka、Scala、flume、hive等兼容版本【适用于任何版本】

方法当我们安装spark的时候，很多时候都会遇到这个问题,如何找到对应spark的各个组件的版本，找到比较标准的版本兼容信息。答案在spark源码中的pom文件。首先我们从官网下载源码。进入官网http://spark.apache.org选择download，然后我们看到下面内容# Master development branch git clone git://github.com/apa....