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

flink-cdc可以使用 flink 的 kafka avro格式对接吗?

flink-cdc写入 Upsert Kafka avro格式可以使用 flink 的 kafka avro格式对接吗?

EventBridge的steaming，上游可以对接kafka，也可以对接EB自己的BUS，下游？

EventBridge的steaming，上游可以对接kafka，也可以对接EB自己的BUS，下游对接是clickhouse。这个方案与kafka直接对接clickhouse有什么区别？一般不超过64kb，假如EB支持直接写入指定clickhouse就完美了，clickhouse要求批量写，这个跟其...

消息队列Kafka入门课程

4 课时 |

3098 人已学 |

加入学习

分布式消息系统 Kafka 快速入门

24 课时 |

640 人已学 |

加入学习

有个问题请教下大家，我这边用的flink版本是1.13.2的，需要对接kafka的数据写入到多张hi

有个问题请教下大家，我这边用的flink版本是1.13.2的，需要对接kafka的数据写入到多张hive数据表，在使用tableapi的时候发现会启动多个job，请问下是否能只启动一个job的情况下写入多张hive数据表? 提交的时候只有一段flink run，但是从接下来的提示及yarn都显示出其...

大佬们，Flink对接Kafka结果Kafka的元数据（事务ID，Offset之类）找不到了咋办？!

大佬们，Flink对接Kafka结果Kafka的元数据（事务ID，Offset之类）找不到了咋办？我这是磁盘满了。 Flink 先消费Kafka 再写Kafka ，中间断了两周，然后再从两周前的检查点启动就起不来了

Flink初试——对接Kafka

本篇文章我们用 Flink Kafka Connector对接Kafka，实现一个简单的报警业务。我们暂时不去谈论理论，先上手实现这个简单的需求。flink-connector-kafka是 flink 内置的Kafka连接器，包含了从topic读取数据的Flink Kafka Consumer 和...

canalv1.1.2使用HA模式对接kafka

环境信息 canal 1.1.2 mysql 5.6 问题描述 canal server HA模式下使用tcp模式，发生主备切换时可以正常解析binlog的接收binlog 对接kafka时，发生主备切换后不再正常解析和接收binlog 手动停止当前running的节点后，主备切换成功了，inst...

canal adapter中只用tcp消费模式使用zk做了高可用，对接kafka和rocketMQ时

在canal adapter中只用tcp消费模式使用zk做了高可用，但是对接kafka和rocketMQ时没有做高可用是否老师增加对接kafka和rocketmq进也使用zk做高可用，类型canal server端高可用的效果，当canal adapter master 异常退出时，stand ...

当我使用canal kafka官方案例对接mysql时报错

canal 版本 canal.deployer-1.1.4 kafka 版本 kafka_2.11-1.1.1 对接时报错：原提问者GitHub用户whx1121

flinksql对接kafka的数据后，用什么format格式可以进行两表关联啊？

kafka对接flume完成测试

1.启动kafka需要提前启动zookeeper，在我的机器里面192.168.52.200 201 202 需启动zk的脚本2.启动kafka 到bin下三台全部启动bin/kafka-server-start.sh -daemon /root/apps /kafka_2.11-0.10.2.1...