Hi, When sending data using SourceRecord, I want to send to Kafka a byte array but I receive a base64 encoded array of my object. : @Override public SourceRecord[] getRecords(String kafkaTopic) { return new SourceRecord[]{new SourceRecord(null, null, topic.toString(), null, Schema.STRING_SCHEMA, « test key », Schema.BYTES_SCHEMA, mMessage.getPayload())}; }
getPayload returns a byte array. Any help on this would be great ! Many thanks, Marc