Versions Compared

Old Version 7

changes.mady.by.user Konstantine Karantasis

Saved on

compared with

New Version 8

changes.mady.by.user Konstantine Karantasis

Saved on

Key

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

...

When a worker task first detects that a connector is producing to or consuming from a Kafka topic, the worker task will append a record to the status topic with the following format: 

Key formatKey exampleValue formatValue example
topic-${topic-name}:connector-${connector-name}
topic-foo:connector-some-source

{

  "topic": {

    "name": string, 

    "connector": string,

    "task": int32,

    "nametimestamp":  stringint64    

  }
}

{

  "topic": {

    "name": "foo",

    "connector": "some-source",

0    "task":  0,

    "nametimestamp": "foo"1579297899

  }
}

The topic name can be safely separated by the connector name because the delimiter : (colon character) is not a valid topic name character in Kafka. 

...