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.
- No configuration properties need to be changed.
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.