As I a user I need to be able to apply a connector to data stream (topic).

[ajhunyady]

Acceptance criteria

• Connector has the ability to start reading from the beginning or a specific offset of the data stream.
• If a connector restart occurs, it must resume from where it left off.
  • there must be no duplicates or gaps
  • in the event that the resume offset is no longer available, connector must report and error and exit.