Offset Management & Refresh properties of the runner

[zeeshanalisyed]

I have a requirement, regarding the Elasticsearch index I have to change the name every 12 hours means I am preparing the 2 * bigDelta every 24hours. My question is how to completely manage the index name update efficiently. 2ndly I don't want to start collecting each interval from scratch so How Can I manage offsets here. May be you are already doing that but lack of documentation makes it confusing. or do I need to read in kafka-connect package documentation?