|
|
@@ -333,7 +333,7 @@ public class BaseBusiness {
|
|
|
ycSendConsumeInfo.setTermRecordID(vo.getTermRecordId());
|
|
|
ycSendConsumeInfo.setPosRecordState(vo.getRecordStatus().intValue());
|
|
|
|
|
|
- kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.OLD_SYNC_TOPIC, EventTypeConstants.CONSUME_RECORD, EventSenderEnum.OLD.code(), vo);
|
|
|
+ kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.OLD_SYNC_TOPIC, EventTypeConstants.CONSUME_RECORD, EventSenderEnum.OLD.code(), ycSendConsumeInfo);
|
|
|
}
|
|
|
}
|
|
|
}
|