You are viewing an old version of this page. View the current version.

Compare with Current View Page History

Version 1 Next »

Status

Current state: "Under Discussion"

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA: here 

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

Currently, the internal name of a windowing join is generated at runtime using a counter to ensure uniqueness within a running topology. When a topology is changed and redeployed, different names can be generated for the same window. This results in lost windowing state without intervention modifying offsets to re-consume the input topics.

Public Interfaces

Proposed Changes

The proposed change would be to add an optional configuration parameter "joinName" to Joined. If provided, this would be used by KStreamImpl to generate internal names when building a join. If not provided the existing name generation would be used.

Compatibility, Deprecation, and Migration Plan

  • Since this is an opt-in, optional parameter there would be no impact on existing code.

  • No labels