title: How to implement Change Data Capture (CDC) using apache spark and kafka?
body: <p>I am using spark-sql-2.4.1v with java 1.8. and kafka versions spark-sql-kafka-0-10_2.11_2.4.3 and kafka-clients_0.10.0.0.</p>
  
  <p>I need to join streaming data with meta-data which is stored in RDS.
  but RDS meta data could be added/changed.</p>
  
  <p>If I read and load RDS table data in application , it would be stale for joining with streaming data.</p>
  
  <p>I  understood ,need to use Change Data Capture (CDC).
  How can I implement Change Data Capture (CDC) in my scenario?</p>
  
  <p>any clues or sample way to implement Change Data Capture (CDC) ?</p>
  
  <p>thanks a lot.</p>