Versions Compared

Key

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

...

If there are alternative ways of accomplishing the same thing, what were they? The purpose of this section is to motivate why the design is the way it is and not some other way.

 

/**
   * SourceConnectors implement the connector interface to pull data from another system and send
   * it to Kafka.
   */
   public abstract class SourceConnector extends Connector {
   
  + public OffsetStorageReader offsetStorageReader() {
  + return ((SourceConnectorContext) context).offsetStorageReader();
  + }
   }