Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
{
  "record": { "type": "object", "optional": false, "keys": {
    "topic": { "type": "string", "optional": false },
    "timestamp": { "type": "int64", "optional": false },
    "timestamp_type": { "type": "int64", "optional": true },
    "partition": { "type": "int32", "optional": false },
    "key": { "type": "object", "optional": true, "keys": {
        "schema": { "type": "string", "optional": false },
        "object": { "type": "string", "optional": false }
      } },
    "value": { "type": "object", "optional": true, "keys": {
        "schema": { "type": "string", "optional": false },
        "object": { "type": "string", "optional": false }
      } },
    "headers": { "type": "object", "optional": true, "keys": {
        "schema": { "type": "string", "optional": false },
        "object": { "type": "string", "optional": false }
      } },
    "offset": { "type": "int32", "optional": true },
    "source_partition": { "type": "object", "optional": true, "keys": {} },
    "source_offset": { "type": "object", "optional": true, "keys": {} }
    } },
  "index": { "type": "int32", "optional": false },
  "exception": { "type": "string", "optional": false },
  "attempt": { "type": "int32", "optional": false },
  "task_id": { "type": "string", "optional": false },
  "time_of_error": { "type": "int64", "optional": false },
  "stages": { "type": "array", "optional": false, "keys": { 
    "type": { "type": "string" },
    "config": { "type": "object", "optional": true, "keys": {} },
    "class": { "type": "string", "optional": false } 
  } }
}

...