Hey Guys,

i am working on JDBC Sink Conneector to take data from kafka topic to mysql.

i am having 2 questions.

i am using normal Apache Kafka 2.5 not a confluent version.

1)For inserting data every time we need to add the schema data also with
every data,How can i overcome this situation?i want to give only the data.

2)In certain time i need to update the existing record without adding as a
new record.How can i achieve this?

Reply via email to