Struct

This example converts the bytes field from a byte array to a string.

Input

{
  "topic" : "topic",
  "kafkaPartition" : 1,
  "valueSchema" : {
    "type" : "BYTES",
    "isOptional" : false
  },
  "value" : "dGhpcyBpcyBhIHRlc3Q=",
  "timestampType" : "NO_TIMESTAMP_TYPE",
  "offset" : 1,
  "headers" : [ ]
}

Change(s) in the output are emphasized if delta(s) are detected.

Output

{
  "topic" : "topic",
  "kafkaPartition" : 1,
  "valueSchema" : {
    "type" : "STRING",
    "isOptional" : false
  },
  "value" : "this is a test",
  "timestampType" : "NO_TIMESTAMP_TYPE",
  "offset" : 1,
  "headers" : [ ]
}