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
