I have developed kafka-sink-connector (using confluent-oss-3.2.0-2.11, connect framework) for my data-store (Amppol ADS), which stores data from kafka topic to corresponding table in my store. Every thing is working as expected as long as kafka servers and ADS servers are up and running. Need a help/suggestions about a specific use-case where events are getting ingested in kafka topics and underneath sink component (ADS) is down. Expectation here is Whenever a sink servers comes up, records that were ingested earlier in kafka topics should be inserted into the tables;
Kindly advise how to handle such a case. Is there any support available in connect framework for this..? or atleast some references will be a great help. Nilkanth Patel.
