产生的json数据：
{
"table":"GG.TCUSTORD",
"op_type":"I",
"op_ts":"2017-04-18 08:27:47.088201",
"current_ts":"2017-04-18T16:27:52.881000",
"pos":"00000000540000002348",
"tokens":{
"TK-SCN":"1245602",
"TK-OSUSER":"oracle",
"TK-HOST":"ray"
},
"after":{
"CUST_CODE":"WILL",
"ORDER_DATE":"1994-09-30:15:33:00",
"PRODUCT_CODE":"CAR",
"ORDER_ID":"333333333",
"PRODUCT_PRICE":17520.00,
"PRODUCT_AMOUNT":3,
"TRANSACTION_ID":"100"
}
}
解析后的数据：
GG.TCUSTORD;1245602;I;2017-04-18T16:27:52.881000;0::WILL,1::1994-09-30:15:33:00,2::CAR,3::333333333,4::17520.00,5::3,6::100
是需要在kafka producer端序列化来实现，还是有什么其他方法？
JSON应该是一种格式的字符串，他本身就是字符串了，不用再解析成字符串，因此应该是可以直接当kafka的消息发送的。我看你的解析后的数据：GG.TCUSTORD;1245602;I;2017-04-18T16:27:52.881000;0::WILL,1::1994-09-30:15:33:00,2::CAR,3::333333333,4::17520.00,5::36::100；
应该是你的producer发送数据的时候有一个自己的数据压缩算法，把json压缩成这种格式的，不是序列化，序列化一般是把对象序列化成二进制的数据。