You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The type of kafka messages I'm getting is json string, (not Avro) and the format of the json is nested json. (The json message is at the below.)
I want to make an output in the following format :
appId=XXXX/date_id=YYYY-MM-dd/hour_id=HH
In summary, it's as follows,
*not avro type
*nested json
can I make it into that format?
Hi.
I have some questions to use your library.
The type of kafka messages I'm getting is json string, (not Avro) and the format of the json is nested json. (The json message is at the below.)
I want to make an output in the following format :
appId=XXXX/date_id=YYYY-MM-dd/hour_id=HH
In summary, it's as follows,
{ "header": { "publishTime": 1678351663207, "topicId": "lv20LogbucketLogKafka", "code": "resource", "txNo": 0, "partitionKey": "990312129142715", "appId": "703692", "topicName": "703692-ResourceLog-qa", "qid": 4852333281835336565, "jsonObj": "map" }, "body": { "tag1": null, "repair": false, "publishTime": 1678351663206, "code": "resource", "src": "p1", "slot": 1678351500000, "tag2": null, "logBody": { "accountId": "00000000", "amount": 13628215, "appId": "703692", "channelId": "0_1", "character1Id": "00000000", "character1Nm": "00000000" }, "split": 1, "appId": "703692", "logId": "0e70d060-be57-11ed-b8db-179f3951784b", "marketOrderId": null, "maxSplit": 3, "playerId": "00000000" }, "uri": "log_playerLog" }*not avro type
*nested json
can I make it into that format?
Thanks for your time.
The text was updated successfully, but these errors were encountered: