public ProcessingContext<ConsumerRecord<byte[], byte[]>> context() {
        return context;
    }
Return the context used to process this record

@return the processing context; never null
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java