可以尝试:在已接触的项目中DMHS可以推送到KAFKA消息，如下是json配置，可以参考DMHS-Reference-Guide-kafka.pdf手册。
--配置参考如下
#DMHS KAFKA JSON FORMAT
char_replace=(",")
lob_piece=0
clob_format=char
old_lob_flag=--
#set_json_version=2.0
opcmd_len=8
need_crlf=0
set_null=1
set_quota=0
old_values=ALL lob_piece
new_values=ALL
json_format_ins={"schema":"#SCHEMA","table":"#TABLE","op_type":"#OP_TYPE","op_time":"#OP_TIME","commit_time":"#COMMIT_TIME","primary_keys":[#PRIMARY_KEY],"after":{#NEW_VALUES}}
json_format_upd={"schema":"#SCHEMA","table":"#TABLE","op_type":"#OP_TYPE","op_time":"#OP_TIME","commit_time":"#COMMIT_TIME","primary_keys":[#PRIMARY_KEY],"before":{#OLD_VALUES},"after":{#NEW_VALUES}}
json_format_del={"schema":"#SCHEMA","table":"#TABLE","op_type":"#OP_TYPE","op_time":"#OP_TIME","commit_time":"#COMMIT_TIME","primary_keys":[#PRIMARY_KEY],"before":{#OLD_VALUES}}
json_format_ddl={"schema":"#SCHEMA","table":"#TABLE","op_type":"#OP_TYPE","op_time":"#OP_TIME","commit_time":"#COMMIT_TIME","ddl":"#DDL_SQL"}