Hello, I’m not sure if you are the same person, or work with the person who posted a similar question on Slack, but, just in case this is an unrelated coincidence…
You should be able to use ConnectRecord.header().add() to add a header. I’ve used something similar to read headers on incoming messages in an SMT. More info here: https://downloads.apache.org/kafka/2.3.0/javadoc/org/apache/kafka/connect/connector/ConnectRecord.html <https://downloads.apache.org/kafka/2.3.0/javadoc/org/apache/kafka/connect/connector/ConnectRecord.html> > On Aug 3, 2020, at 4:19 AM, vishnu murali <vishnumurali9...@gmail.com> wrote: > > Hi everyone > > I am getting data from SFTP CSV Source connector. > > In this I need to add header with that message for consuming in Java side. > > So anyone knows how to add header in the message while using connector? > > Thanks in advance 😊.....
