Versions Compared

Old Version 22

changes.mady.by.user Mason Chen

Saved on

compared with

New Version 23

changes.mady.by.user Mason Chen

Saved on

Key

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

...

This enumerator context proxy facilitates the ability to close executors used by scheduled callables in the underlying KafkaSourceEnumerators and wraps the KafkaPartitionSplits with cluster information. This also handles errors with the scheduled callables when metadata is not sync with source state.

...