[KAFKA-7480] GlobalThread should honor custom auto.offset.reset policy

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Labels: needs-kip new-streams-runtime-should-fix
• Assignee: Navinder Brar
• Reporter: Matthias J. Sax
• Created: 04/Oct/18 15:10
• Updated: 04/Mar/22 19:01

Description

With KAFKA-6121 we improved Kafka Streams resilience and correctness with regard to consumer auto.offset.reset and state cleanup.

Back than, we decided to let GlobalStreamThread die and not handle InvalidOffsetException during regular processing, because this error indicates a fatal issue and the user should be notified about it. However, as reported on the user mailing list, the only thing a user can do is, to restart the application (and investigate the root cause). During restart, the state will be cleaned up and bootstrapped correctly.

Thus, we might want to allow users to specify a more resilient configuration for this case and log an ERROR message if the error occurs. To ensure consistency, we might not allow to set reset policy "latest" though (need discussion)? By default, we can still keep "none" and fail.

Note: `Topology.addGlobalStore` does not allow to set a reset policy. Thus, this might require a KIP to extend `Topology.addGlobalStore` accordingly.

Issue Links

• is related to: KAFKA-12550 Introduce RESTORING state to the KafkaStreams FSM