马shi兵hotspot源码

@Override  public DeserializationHandlerResponse handle(ProcessorContext context,      ConsumerRecord<byte[], byte[]> record, Exception exception) {    log.error("Exception caught during Deserialization, sending to the source topic, " +            "taskId: {}, topic: {}, partition: {}, offset: {}",        context.taskId(), record.topic(), record.partition(), record.offset(),        exception);