플러그인별 로그 포맷 - kayform/bwcontrol GitHub Wiki

플러그인별 로그 포맷

1. wal2json

{
        "kind": "insert",
        "schema": "public",
        "table": "emp_org",
        "columnnames": ["empname", "salary"],
        "columntypes": ["text", "int4"],
        "columnvalues": ["2275d06336229cd9fb15ffae7e87fefb", 700213]
}

2.kafka-console-consumer

{"empname":{"string":"d9d8cdbb948568b5545402ce8df135d1"}}       {"empname":{"string":"d9d8cdbb948568b5545402ce8df135d1"},"salary":{"int":1}}
{"empname":{"string":"1a23896f6e7e6641e1d52acb0f26229d"}}       {"empname":{"string":"1a23896f6e7e6641e1d52acb0f26229d"},"salary":{"int":1}}
{"empname":{"string":"304b36fe7cd582fc173966915baa48be"}}       {"empname":{"string":"304b36fe7cd582fc173966915baa48be"},"salary":{"int":1}}
{"empname":{"string":"ef32225d8730182a88cd10e512905750"}}       {"empname":{"string":"ef32225d8730182a88cd10e512905750"},"salary":{"int":1}}

3.BW test

new schema for relid=26845
key = {"type":"record","name":"emp_topic_pkey","namespace":"com.martinkl.bottledwater.dbschema.public","fields":[{"name":"empname","type":[{"type":"null"},{"type":"string"}]}]}
row = {"type":"record","name":"emp_topic","namespace":"com.martinkl.bottledwater.dbschema.public","fields":[{"name":"empname","type":[{"type":"null"},{"type":"string"}]},{"name":"salary","type":[{"type":"null"},{"type":"int"}]}]}
insert to emp_topic: {"empname": {"string": "bd73e4086d72b3cedbe3b40fa787d6aa"}} --> {"empname": {"string": "bd73e4086d72b3cedbe3b40fa787d6aa"}, "salary": {"int": 1}}
commit xid=2382 wal_pos=3/4D842240

begin xid=2383 wal_pos=3/4D842278
insert to emp_topic: {"empname": {"string": "8a3e4fc2bb4aedf6ff03a9db48c20ea7"}} --> {"empname": {"string": "8a3e4fc2bb4aedf6ff03a9db48c20ea7"}, "salary": {"int": 1}}
		commit xid=2383 wal_pos=3/4D842368



begin xid=2384 wal_pos=3/4D842368
insert to emp_topic: {"empname": {"string": "1d6fe8474d4e5f4748e9390ab6da1c58"}} --> {"empname": {"string": "1d6fe8474d4e5f4748e9390ab6da1c58"}, "salary": {"int": 1}}
commit xid=2384 wal_pos=3/4D842458



              


           
⚠️ **GitHub.com Fallback** ⚠️