[KAFKA-10410] OnRestoreStart disappeared from StateRestoreCallback in 2.6.0 and reappeared in a useless place

• Type: Bug
• Status: Open
• Priority: Blocker
• Resolution: Unresolved
• Affects Version/s: 2.6.0
• Component/s: streams
• Labels: new-streams-runtime-should-fix
• Assignee: Unassigned
• Reporter: Mark Shelton
• Created: 17/Aug/20 20:47
• Updated: 12/May/22 22:21

Description

In version 2.5.0 and earlier there are "onRestoreStart" and "onRestoreEnd" methods on StateRestoreCallback.

Version 2.6.0 removed these calls and put them into StateRestoreListener and requires "streaming.setGlobalStateRestoreListener".

This makes it impossible for the actual StateRestoreCallback implementation to receive the start and end indication and is blocking me from moving to 2.6.0.

See:

https://kafka.apache.org/25/javadoc/index.html?org/apache/kafka/streams/processor/AbstractNotifyingRestoreCallback.html 

Related JIRA:

https://issues.apache.org/jira/browse/KAFKA-4322