Versions Compared

Old Version 33

changes.mady.by.user Mason Chen

Saved on

compared with

New Version 34

changes.mady.by.user Mason Chen

Saved on

Key

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

...

A default implementation will be provided so that native Kubernetes configmap can easily control the metadata (yaml/json file).  This implementation is targeted for the basic use cases where external monitoring will inform how users change the metadata.

In addition, KafkaStream is introduced as abstraction that contains a logical mapping to physical Kafka clusters and Kafka topics, which can be used to derive metadata for source state. Changes in metadata are detected by the source enumerator and propagated to source reader via source events to reconcile the changes.

...