Unable to encode element ‘org.apache.beam.sdk.io.kafka.KafkaRecord@6f30ad3’ with coder ‘KafkaRecordCoder(ByteArrayCoder,ByteArrayCoder)’

I am trying to run a pipeline using apache-beam with source as one kafka topic and destination as another kafka topic. I have written my code and is working well(ie, no error in code I think). But whenever I try to push any msg from my source topic i get this error > WARNING:root:Make sure … Read more