def __init__(self, store_name, context) -> None:
        self.topic = f'{context.application_id}-{store_name}-changelog'
        self.context = context
        self.partition = context.task_id.partition
        self.record_collector = context.state_record_collector