Guest User

Untitled

a guest
Jun 17th, 2021
84
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. {
  2.   "schema":{
  3.     "type":"struct",
  4.     "fields":[
  5.       {
  6.         "type":"int32",
  7.         "optional":false,
  8.         "field":"id"
  9.       }
  10.     ],
  11.     "optional":false,
  12.     "name":"data.cdc.dbname.Key"
  13.   },
  14.   "payload":{
  15.     "id":1005
  16.   }
  17. }{
  18.   "schema":{
  19.     "type":"struct",
  20.     "fields":[
  21.       {
  22.         "type":"struct",
  23.         "fields":[
  24.           {
  25.             "type":"int32",
  26.             "optional":false,
  27.             "field":"id"
  28.           },
  29.           {
  30.             "type":"string",
  31.             "optional":false,
  32.             "field":"first_name"
  33.           },
  34.           {
  35.             "type":"string",
  36.             "optional":false,
  37.             "field":"last_name"
  38.           },
  39.           {
  40.             "type":"string",
  41.             "optional":false,
  42.             "field":"email"
  43.           }
  44.         ],
  45.         "optional":true,
  46.         "name":"data.cdc.dbname.Value",
  47.         "field":"before"
  48.       },
  49.       {
  50.         "type":"struct",
  51.         "fields":[
  52.           {
  53.             "type":"int32",
  54.             "optional":false,
  55.             "field":"id"
  56.           },
  57.           {
  58.             "type":"string",
  59.             "optional":false,
  60.             "field":"first_name"
  61.           },
  62.           {
  63.             "type":"string",
  64.             "optional":false,
  65.             "field":"last_name"
  66.           },
  67.           {
  68.             "type":"string",
  69.             "optional":false,
  70.             "field":"email"
  71.           }
  72.         ],
  73.         "optional":true,
  74.         "name":"data.cdc.dbname.Value",
  75.         "field":"after"
  76.       },
  77.       {
  78.         "type":"struct",
  79.         "fields":[
  80.           {
  81.             "type":"string",
  82.             "optional":false,
  83.             "field":"version"
  84.           },
  85.           {
  86.             "type":"string",
  87.             "optional":false,
  88.             "field":"connector"
  89.           },
  90.           {
  91.             "type":"string",
  92.             "optional":false,
  93.             "field":"name"
  94.           },
  95.           {
  96.             "type":"int64",
  97.             "optional":false,
  98.             "field":"ts_ms"
  99.           },
  100.           {
  101.             "type":"string",
  102.             "optional":true,
  103.             "name":"io.debezium.data.Enum",
  104.             "version":1,
  105.             "parameters":{
  106.               "allowed":"true,last,false"
  107.             },
  108.             "default":"false",
  109.             "field":"snapshot"
  110.           },
  111.           {
  112.             "type":"string",
  113.             "optional":false,
  114.             "field":"db"
  115.           },
  116.           {
  117.             "type":"string",
  118.             "optional":false,
  119.             "field":"schema"
  120.           },
  121.           {
  122.             "type":"string",
  123.             "optional":false,
  124.             "field":"table"
  125.           },
  126.           {
  127.             "type":"int64",
  128.             "optional":true,
  129.             "field":"txId"
  130.           },
  131.           {
  132.             "type":"int64",
  133.             "optional":true,
  134.             "field":"lsn"
  135.           },
  136.           {
  137.             "type":"int64",
  138.             "optional":true,
  139.             "field":"xmin"
  140.           }
  141.         ],
  142.         "optional":false,
  143.         "name":"io.debezium.connector.postgresql.Source",
  144.         "field":"source"
  145.       },
  146.       {
  147.         "type":"string",
  148.         "optional":false,
  149.         "field":"op"
  150.       },
  151.       {
  152.         "type":"int64",
  153.         "optional":true,
  154.         "field":"ts_ms"
  155.       },
  156.       {
  157.         "type":"struct",
  158.         "fields":[
  159.           {
  160.             "type":"string",
  161.             "optional":false,
  162.             "field":"id"
  163.           },
  164.           {
  165.             "type":"int64",
  166.             "optional":false,
  167.             "field":"total_order"
  168.           },
  169.           {
  170.             "type":"int64",
  171.             "optional":false,
  172.             "field":"data_collection_order"
  173.           }
  174.         ],
  175.         "optional":true,
  176.         "field":"transaction"
  177.       }
  178.     ],
  179.     "optional":false,
  180.     "name":"data.cdc.dbname.Envelope"
  181.   },
  182.   "payload":{
  183.     "before":null,
  184.     "after":{
  185.       "id":1005,
  186.       "first_name":"foo",
  187.       "last_name":"bar",
  188.       "email":"foo@bar.com"
  189.     },
  190.     "source":{
  191.       "version":"1.2.3.Final",
  192.       "connector":"postgresql",
  193.       "name":"dbserver1",
  194.       "ts_ms":1600374991648,
  195.       "snapshot":"false",
  196.       "db":"postgres",
  197.       "schema":"public",
  198.       "table":"customers",
  199.       "txId":602,
  200.       "lsn":34088472,
  201.       "xmin":null
  202.     },
  203.     "op":"c",
  204.     "ts_ms":1600374991762,
  205.     "transaction":null
  206.   }
  207. }{
  208.   "schema":{
  209.     "type":"struct",
  210.     "fields":[
  211.       {
  212.         "type":"int32",
  213.         "optional":false,
  214.         "field":"id"
  215.       }
  216.     ],
  217.     "optional":false,
  218.     "name":"data.cdc.dbname.Key"
  219.   },
  220.   "payload":{
  221.     "id":1005
  222.   }
  223. }{
  224.   "schema":{
  225.     "type":"struct",
  226.     "fields":[
  227.       {
  228.         "type":"struct",
  229.         "fields":[
  230.           {
  231.             "type":"int32",
  232.             "optional":false,
  233.             "field":"id"
  234.           },
  235.           {
  236.             "type":"string",
  237.             "optional":false,
  238.             "field":"first_name"
  239.           },
  240.           {
  241.             "type":"string",
  242.             "optional":false,
  243.             "field":"last_name"
  244.           },
  245.           {
  246.             "type":"string",
  247.             "optional":false,
  248.             "field":"email"
  249.           }
  250.         ],
  251.         "optional":true,
  252.         "name":"data.cdc.dbname.Value",
  253.         "field":"before"
  254.       },
  255.       {
  256.         "type":"struct",
  257.         "fields":[
  258.           {
  259.             "type":"int32",
  260.             "optional":false,
  261.             "field":"id"
  262.           },
  263.           {
  264.             "type":"string",
  265.             "optional":false,
  266.             "field":"first_name"
  267.           },
  268.           {
  269.             "type":"string",
  270.             "optional":false,
  271.             "field":"last_name"
  272.           },
  273.           {
  274.             "type":"string",
  275.             "optional":false,
  276.             "field":"email"
  277.           }
  278.         ],
  279.         "optional":true,
  280.         "name":"data.cdc.dbname.Value",
  281.         "field":"after"
  282.       },
  283.       {
  284.         "type":"struct",
  285.         "fields":[
  286.           {
  287.             "type":"string",
  288.             "optional":false,
  289.             "field":"version"
  290.           },
  291.           {
  292.             "type":"string",
  293.             "optional":false,
  294.             "field":"connector"
  295.           },
  296.           {
  297.             "type":"string",
  298.             "optional":false,
  299.             "field":"name"
  300.           },
  301.           {
  302.             "type":"int64",
  303.             "optional":false,
  304.             "field":"ts_ms"
  305.           },
  306.           {
  307.             "type":"string",
  308.             "optional":true,
  309.             "name":"io.debezium.data.Enum",
  310.             "version":1,
  311.             "parameters":{
  312.               "allowed":"true,last,false"
  313.             },
  314.             "default":"false",
  315.             "field":"snapshot"
  316.           },
  317.           {
  318.             "type":"string",
  319.             "optional":false,
  320.             "field":"db"
  321.           },
  322.           {
  323.             "type":"string",
  324.             "optional":false,
  325.             "field":"schema"
  326.           },
  327.           {
  328.             "type":"string",
  329.             "optional":false,
  330.             "field":"table"
  331.           },
  332.           {
  333.             "type":"int64",
  334.             "optional":true,
  335.             "field":"txId"
  336.           },
  337.           {
  338.             "type":"int64",
  339.             "optional":true,
  340.             "field":"lsn"
  341.           },
  342.           {
  343.             "type":"int64",
  344.             "optional":true,
  345.             "field":"xmin"
  346.           }
  347.         ],
  348.         "optional":false,
  349.         "name":"io.debezium.connector.postgresql.Source",
  350.         "field":"source"
  351.       },
  352.       {
  353.         "type":"string",
  354.         "optional":false,
  355.         "field":"op"
  356.       },
  357.       {
  358.         "type":"int64",
  359.         "optional":true,
  360.         "field":"ts_ms"
  361.       },
  362.       {
  363.         "type":"struct",
  364.         "fields":[
  365.           {
  366.             "type":"string",
  367.             "optional":false,
  368.             "field":"id"
  369.           },
  370.           {
  371.             "type":"int64",
  372.             "optional":false,
  373.             "field":"total_order"
  374.           },
  375.           {
  376.             "type":"int64",
  377.             "optional":false,
  378.             "field":"data_collection_order"
  379.           }
  380.         ],
  381.         "optional":true,
  382.         "field":"transaction"
  383.       }
  384.     ],
  385.     "optional":false,
  386.     "name":"data.cdc.dbname.Envelope"
  387.   },
  388.   "payload":{
  389.     "before":{
  390.       "id":1005,
  391.       "first_name":"foo",
  392.       "last_name":"bar",
  393.       "email":"foo@bar.com"
  394.     },
  395.     "after":{
  396.       "id":1005,
  397.       "first_name":"egg",
  398.       "last_name":"bar",
  399.       "email":"foo@bar.com"
  400.     },
  401.     "source":{
  402.       "version":"1.2.3.Final",
  403.       "connector":"postgresql",
  404.       "name":"dbserver1",
  405.       "ts_ms":1600375609365,
  406.       "snapshot":"false",
  407.       "db":"postgres",
  408.       "schema":"public",
  409.       "table":"customers",
  410.       "txId":603,
  411.       "lsn":34089688,
  412.       "xmin":null
  413.     },
  414.     "op":"u",
  415.     "ts_ms":1600375609778,
  416.     "transaction":null
  417.   }
  418. }
RAW Paste Data