Source MySQL table data to Kafka | Build JDBC Source Connector | Confluent Connector | Kafka Connect 

Dear Vishal, Thank you for your effort & time to produce & upload these tutorials.

Nice video bro. It worked for me. One quick question for you: How to run query like this: select id,CUST_LN_NBR FROM flex_activity limit 1; In this query I am using limit option in due to that it is getting failed. If I use simple query without limit then it works fine: Error I am getting: org.apache.kafka.connect.errors.ConnectException: java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'WHERE `ID` > -1 ORDER BY `ID` ASC' at line 1 This is not only with limit option, this is for all whenever you have to apply any filter.

Very helpful video. I see the 'timestamp.column.name' should have been TXN_DATE (as flashed up on video) otherwise update wont work. It would have been nice to see this working at the end in addition to adding new records

AWESOME !!.Can you also upload video on sink connector to oracle database or any rdbms

Thank for the great tutorial. Did you have to create the avro schema or it gets generated?

Hi Vishal, I am facing issue Invalid connector configuration: There are 2 fields that require your attention while connecting to mysql db ..is this required mysql jdbc configuration as well ? if yes how we can do that ?

Really cool bro!

I'm beginner on kafka and DB concepts. What is dialect exactly in this case ?

Could you please do a Video loading tables into their respective topics for each tables , using SQL SERVER as a source??.... so everytime each table suffers a DML action the new event s sent to the Confluent plataform..

Hi, Vishal , Could you please help me in pushing confluent topic data into scylladb table...

Great video! Can you help with connecting to snowflake as source?

wtf , you are good

Hi Vishal thanks for sharing videos. Please let me know where can i check the errors/logs when connectors failed? also logs/errors if any issues in processing data. Please share me paths

Hi Vishal, thank you very much for this! :) I have 1 question, how do you installed the connector plugin for sink ?

Hi Vishal, Could you please help me with Snowflake Source connector via (JDBC) to unload the data to Confluent Kafka. If there's any sample code please share me the github details.

Please, what is the best method or connector available to pull or ingest data that normally get updated or changed. For example bank accounts statement. Thanks.

Sir nice video, but atleast you can upload the code link.

Hey, i tried to connect to postgreSQL and was finally landing with below error in logs Caused by: org.apache.kafka.common.errors.SerializationException: Error serializing Avro message Caused by: org.apache.kafka.connect.errors.DataException: Failed to serialize Avro data from topic any help ?

hi by using your code connector is got connected but status is got failed and no data is fetched from db can i know what was the reason

hi Vishal, when i want to upload the connector i faced the issue "invalid connector class" i need advice. thanks

can you give us the link for the config file ?

Thanks for the video , Vishal. I wanted to know that , we can also source Oracle DB using JDBC Source Connector too, isn't it? And where did you deploy the connector config file? In the Confluent cloud?

Can you please guide me how we do this in local instead of confluent cloud? What I want to do is like to connect database with kafka connect and the data gets inserted into kafka cluster

My Confluent installation dont have JDBC source connector by default , Please help me how to install ?

Sir Can you provide the jdbc driver link

how to download kafka connect JDBC COnnector

Could you please provide me the link

Can anyone would paste the config properties in comment.

thanks i need your email please

from oracle, it is unable to fetch data. Any license issue?