Commit 5102d7e6 authored by liaozan's avatar liaozan 🏀

Update

parent 52b23f8f
......@@ -20,6 +20,10 @@ public class ConvertUtils {
public static <Target> Target convertTo(ConsumerRecord<String, String> record, Class<Target> targetType) {
CanalChangedEvent event = JacksonUtils.getObjectFromJson(record.value(), CanalChangedEvent.class);
return convertTo(event, targetType);
}
public static <Target> Target convertTo(CanalChangedEvent event, Class<Target> targetType) {
if (event == null) {
throw new BaseException("CanalChangedEvent is null");
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment