如何正确配置Apache Camel PostgreSQL Debezium组件输出Cloud Events？

• 核心配置逻辑：Camel的Debezium组件需要直接传递Debezium原生的Cloud Events转换器配置，而非仅依赖internalValueConverter或简单的additionalProperties映射。

• XML配置示例：

<bean id="postgresDebeziumConfig" class="io.debezium.connector.postgresql.PostgresConnectorConfig">
    <constructor-arg>
        <map>
            <!-- 基础数据库连接配置 -->
            <entry key="database.hostname" value="你的数据库地址"/>
            <entry key="database.port" value="5432"/>
            <entry key="database.user" value="数据库用户名"/>
            <entry key="database.password" value="数据库密码"/>
            <entry key="database.dbname" value="目标数据库名"/>
            <entry key="database.server.name" value="postgres-server"/>
            <!-- Cloud Events转换器核心配置 -->
            <entry key="value.converter" value="io.debezium.converters.CloudEventsConverter"/>
            <entry key="value.converter.schema.enable" value="false"/>
            <!-- Cloud Events可选配置 -->
            <entry key="cloud.events.data.content.type" value="application/json"/>
            <entry key="cloud.events.id.source" value="//postgres-server/目标数据库名"/>
        </map>
    </constructor-arg>
</bean>

<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route>
        <from uri="debezium-postgresql://connector?config=#postgresDebeziumConfig"/>
        <to uri="你的目标端点"/>
    </route>
</camelContext>

• Java DSL配置示例：

DebeziumPostgresComponent debeziumComponent = new DebeziumPostgresComponent(camelContext);
Map<String, Object> configMap = new HashMap<>();

// 基础数据库配置
configMap.put("database.hostname", "你的数据库地址");
configMap.put("database.port", 5432);
configMap.put("database.user", "数据库用户名");
configMap.put("database.password", "数据库密码");
configMap.put("database.dbname", "目标数据库名");
configMap.put("database.server.name", "postgres-server");

// Cloud Events转换器配置
configMap.put("value.converter", "io.debezium.converters.CloudEventsConverter");
configMap.put("value.converter.schema.enable", "false");
configMap.put("cloud.events.data.content.type", "application/json");
configMap.put("cloud.events.id.source", "//postgres-server/目标数据库名");

debeziumComponent.setConfiguration(configMap);
camelContext.addComponent("debezium-postgres", debeziumComponent);

// 定义路由
from("debezium-postgres://connector")
    .to("你的目标端点");

• 关键注意事项：
  1. 必须显式设置value.converter为io.debezium.converters.CloudEventsConverter，同时关闭value.converter.schema.enable——Cloud Events不需要Debezium的Schema信息。
  2. internalValueConverter是Camel组件内部的转换逻辑，和Debezium原生转换器不属于同一层级，仅设置它无法触发Cloud Events输出。
  3. 若使用additionalProperties，需完整传递所有Cloud Events相关配置，包括value.converter及配套参数，不能仅单独设置转换器类名。

内容的提问来源于stack exchange，提问作者user3029642