Flink CDC写入rabbitMq指定exchange有案例么？

可以的，Flink CDC 可以写入 RabbitMQ 的指定 exchange。

你可以参考以下步骤：

创建一个 RabbitMQ 的 exchange。
配置 Flink CDC 的 Kafka 生产者配置，指定 exchange 和 routing-key。
启动 Flink CDC 的任务。
使用 Canal 或 Debezium 等工具从数据库中读取数据，并将数据写入 Flink CDC 的 Kafka 主题。
数据会被写入 RabbitMQ 的指定 exchange。
以下是一个具体的示例：

// 创建一个 RabbitMQ 的 exchange
rabbitmqctl add exchange my-exchange direct

// 配置 Flink CDC 的 Kafka 生产者配置
properties:
producer:
bootstrap.servers: localhost:9092
acks: all
retries: 10
exchange: my-exchange
routing-key: my-routing-key

// 启动 Flink CDC 的任务
flink run -d -p 1 my-cdc-job.jar

// 使用 Canal 或 Debezium 等工具从数据库中读取数据，并将数据写入 Flink CDC 的 Kafka 主题

// 数据会被写入 RabbitMQ 的指定 exchange