Hi, I am new to Kafka JDBC Connect, working on Sales_Order database. while working in insert through query its working fine. But I need to update some of records the same time , but this is not working. I have taken Oracle DB for this. for insertion, I have used below file. { name= my-jdbc-conn…

Hi, Please, help me to understand how can we achieve, update events through kafka source connector. I have stuck up with this issue. I needs to do both insert and update options with single query. where as Insertition is working fine, Need to check with update entry. I am not getting any update. …

hey @Anil have a look at the “mode” setting. https://docs.confluent.io/kafka-connectors/jdbc/current/source-connector/source_config_options.html#mode JDBC Source Connector for Confluent Platform | Confluent Documentation Get started with the JDBC Source connector for Confluent Platf…

Hi mmuehlbeyer, Thanks for sharing Information. I need some information about update option. I have taken Timestamp + incrementing mode. I am looking for updated rows only, New rows insertion is working fine. mode= timestamp+incrementing query=SELECT SALES_ORDER, CAST(SO_ITEM AS NUMBER(5,0))…

my Table CREATE TABLE “SOPOOB”.“VJNR_MES_SO_HEADER” ( “SALES_ORDER” VARCHAR2(30), “SO_ITEM” NUMBER(10,0), “MATERIAL” VARCHAR2(30), “QUANTITY” NUMBER(38,3), “UNIT_OF_MEASURE” VARCHAR2(30), “REQUIRED_DATE” DATE, “SOLD_TO_PARTY_NAME” VARCHAR2(40), “SHIP_TO_PARTY_NAME” VARCHAR2(40), “SALES_ORG…

hey, thanks for the update. have look at for what you would like to do : JDBC Source Connector for Confluent Platform | Confluent Documentation Get started with the JDBC Source connector for Confluent Platform. is the query needed? might it be enough to r…

Hi Michael, for oracle table, CREATE TABLE “KAFKA”.“EMP” ( “EMPNO” NUMBER(5,0), “ENAME” VARCHAR2(15), “JOININGDATE” DATE, “RELEASEDATE” DATE, PRIMARY KEY (“EMPNO”) for Postgres, CREATE TABLE public.emp ( empno numeric(5) NOT NULL, ename varchar(15) NULL, joiningdate timestamp NULL, rele…

what happens if you leave the query setting empty?

Confluent Community

Kafka JDBC Source Connector- UPDATE

Kafka Connect

mmuehlbeyer 4 July 2024 10:48 3

hey @Anil

have a look at the “mode” setting.

https://docs.confluent.io/kafka-connectors/jdbc/current/source-connector/source_config_options.html#mode

just to have you on the same page some deep dive how it works.

Topic		Replies	Views
Upsert mode not working as expected Kafka Connect	4	4047	15 April 2021
JDBC Sink connector SMT on upsert mode Kafka Connect	6	8050	15 April 2021
JDBC Connector - differentiating between create and updates Self-Managed Connectors	5	3601	24 November 2022
✍️ Kafka Connect Deep Dive – JDBC Source Connector Self-Managed Connectors	0	3535	17 November 2020
Jdbc sink connector to update a single column in table based on 'riskStatus' in postgres db Kafka Connect	0	3149	11 October 2022

Kafka JDBC Source Connector- UPDATE

Related topics