ChangelogReader (kafka 2.6.1.100-eep-810 API)

All Superinterfaces:

ChangelogRegister

All Known Implementing Classes:

StoreChangelogReader
```
public interface ChangelogReader
extends ChangelogRegister
```
See StoreChangelogReader.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`clear()`	Clear all partitions
`Set<TopicPartition>`	`completedChangelogs()`
`void`	`enforceRestoreActive()`	Transit to restore active changelogs mode
`boolean`	`isEmpty()`
`void`	`restore()`	Restore all registered state stores by reading from their changelogs
`void`	`transitToUpdateStandby()`	Transit to update standby changelogs mode

Methods inherited from interface org.apache.kafka.streams.processor.internals.ChangelogRegister
register, unregister

- Method Detail
  - restore
```
void restore()
```
    Restore all registered state stores by reading from their changelogs
  - enforceRestoreActive
```
void enforceRestoreActive()
```
    Transit to restore active changelogs mode
  - transitToUpdateStandby
```
void transitToUpdateStandby()
```
    Transit to update standby changelogs mode
  - completedChangelogs
```
Set<TopicPartition> completedChangelogs()
```
    Returns:
    
    the changelog partitions that have been completed restoring
  - clear
```
void clear()
```
    Clear all partitions
  - isEmpty
```
boolean isEmpty()
```
    Returns:
    
    whether the changelog reader has just been cleared or is uninitialized