title: How to read the delta of a table from DB into Kafka Producer in java?
body: <p>I am trying to use DB data as my Kafka producer in my java code. The source data grows continuously (say 20 rows per second). The whole data is read from DB and added to the Kafka topic every time a new record is inserted into the DB table. I want only the newly appended rows to be sent to the topic (ie. if the table holds 10 rows already and 4 more rows are appended to it, only those 4 rows need to be sent to the topic).  </p>
  
  <p>Is there a way to achieve this in java, provided we can also use the Kafka API??</p>