问题:
    在通过OGG将Oracle数据推到kafka时,发现EUTIME字段(date类型)在kafka的数据格式有问题,如图:
  OGG for kafka日期格式问题

 

OGG for kafka日期格式问题
可看到,date类型的格式为:yyyy-mm-dd:hh24:mi:ss。
 
解决方法:
    可在replicat进程中,使用OGG的@DATE函数进行日期字段的格式转换,如图:OGG for kafka日期格式问题
OGG for kafka日期格式问题

 

此时再看kafka中数据,日期格式已经正常,如图:
OGG for kafka日期格式问题
 OGG for kafka日期格式问题

 

 

相关文章: