馬shi兵hotspot源碼
2022-11-16 20:21 作者:bili_1559000721 | 我要投稿
@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);
標(biāo)簽：
