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

Reply via email to