Versions Compared

Old Version 4

changes.mady.by.user dan norwood

Saved on

compared with

New Version 5

changes.mady.by.user Konstantine Karantasis

Saved on

Key

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

...

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

"topic": {
  "connector": string,
  "task": int32,
  "name": string,
}

"topic": {
  "connector": "some-source",
  "task": 0,
  "name": "foo",
}

Connect workers reading this topic are computing a map from connector names to sets of topic names. This map represents an up-to-date view of which connectors are using which topics at any time based on the key of these records and whether the value entry of the record is null or non-null. If the most recent record value for a specific topic and a specific connector is non-null, then this topic is considered part of the set of topics that this connector is using. If the most recent record has a null value (is therefore a tombstone record), then the connector is not using this topic anymore. Tombstone records are interpreted by Connect workers as deletion actions of previous topic status records for this connector.

...