Description
Currently, the base class OffsetManager expects a topic as a constructor argument. This is too specific to the use case of the CheckpointOffsetManager which currently requires the kafka topic (will be resolved in #85 ). In fact, this component does not need to manage offsets, but may manage anything which concerns both DataStreamReader and DataStreamWriter.
Tasks
OffsetManager should not require topic as a constructor argument.
OffsetManager should be renamed to StreamManager
The method OffsetManager.configureOffsets should be renamed to configure
Update archetype
Update readmes
How to migrate
Components implementing OffsetManager need to import StreamManager, rename configureOffsets to configure and remove the constructor argument.
Description Currently, the base class
OffsetManagerexpects a topic as a constructor argument. This is too specific to the use case of theCheckpointOffsetManagerwhich currently requires the kafka topic (will be resolved in #85 ). In fact, this component does not need to manage offsets, but may manage anything which concerns bothDataStreamReaderandDataStreamWriter.Tasks
OffsetManagershould not requiretopicas a constructor argument.OffsetManagershould be renamed toStreamManagerOffsetManager.configureOffsetsshould be renamed toconfigureHow to migrate
OffsetManagerneed to importStreamManager, renameconfigureOffsetstoconfigureand remove the constructor argument.