@Override
        protected void appendMessage(StringBuilder builder, ConsumerRecord<byte[], byte[]> msg) {
            builder.append(", where consumed record is ");
            builder.append("{topic='").append(msg.topic()).append('\'');
            builder.append(", partition=").append(msg.partition());
            builder.append(", offset=").append(msg.offset());
            if (msg.timestampType() == TimestampType.CREATE_TIME || msg.timestampType() == TimestampType.LOG_APPEND_TIME) {
                builder.append(", timestamp=").append(msg.timestamp());
                builder.append(", timestampType=").append(msg.timestampType());
            }
            builder.append("}");
        }
Log error context.

@param context the processing context.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java