You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "michael elbaz (Jira)" <ji...@apache.org> on 2022/09/02 11:24:00 UTC

[jira] [Comment Edited] (CAMEL-18427) Camel Debezium with Postgres on Spring Boot doesn't work

    [ https://issues.apache.org/jira/browse/CAMEL-18427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599431#comment-17599431 ] 

michael elbaz edited comment on CAMEL-18427 at 9/2/22 11:23 AM:
----------------------------------------------------------------

[~davsclaus] there is also other bug this is not taken into account on the latest camel version
{code:java}
.append("&timePrecisionMode=connect"){code}


was (Author: michael992):
[~davsclaus] there is also other bug this is not taken into account
{code:java}
.append("&timePrecisionMode=connect"){code}

> Camel Debezium with Postgres on Spring Boot doesn't work
> --------------------------------------------------------
>
>                 Key: CAMEL-18427
>                 URL: https://issues.apache.org/jira/browse/CAMEL-18427
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-debezium
>    Affects Versions: 3.13.0, 3.18.1
>         Environment: Jdk 17
> Windows 10
> Spring boot
>            Reporter: michael elbaz
>            Priority: Minor
>             Fix For: 3.19.0
>
>         Attachments: camel-debezium-postgres.zip, image-2022-08-24-12-12-27-542.png, image-2022-08-24-12-19-55-853.png
>
>
> From camel 3.13.0 Camel Debezium simply not working is work perfectly with camel older than 3.13.0
> (related to this ticket i think https://issues.apache.org/jira/browse/CAMEL-17135)
> here the code
> {code:java}
>     @Override
>     public void configure() throws Exception {
>         String DATABASE_READER = "debezium-postgres:localhost?"
>                 + "databaseHostname=localhost"
>                 + "&databasePort=5432"
>                 + "&databaseUser=postgres"
>                 + "&databasePassword=test"
>                 + "&databaseDbname=test"
>                 + "&databaseServerName=localhost"
>                 + "&schemaWhitelist=public"
>                 + "&tableWhitelist=public.*"
>                 + "&offsetStorageFileName=/tmp/offset-file-1.dat"
>                 + "&offsetFlushIntervalMs=10000"
>                 + "&pluginName=pgoutput";
>         from(DATABASE_READER)
>                 .routeId("debeziumPGRoute")
>                 .log("Response : ${body}");
>     }
> {code}
> !image-2022-08-24-12-12-27-542.png|width=949,height=240!
> I check this [changelog|https://camel.apache.org/releases/release-3.13.0/]
> !image-2022-08-24-12-19-55-853.png|width=803,height=402!
> the pom file
> {code:java}
> <dependency>
>     <groupId>org.apache.camel</groupId>
>     <artifactId>camel-debezium-postgres</artifactId>
> </dependency>
> <dependency>
>     <groupId>org.apache.camel.springboot</groupId>
>     <artifactId>camel-debezium-postgres-starter</artifactId>
> </dependency>{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)