THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Update convertMessages method, to take from the ConsumerRecord the headers and pass them into the created SinkRecord
WorkerSourceTask
- Update sendRecords method, to take from the SourceRecord the headers and pass them into the created ProducerRecord
...