Skip to content

KAFKA-18913: Consider removing state-updater feature flag - 2 #20382

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 4 commits into
base: trunk
Choose a base branch
from

Conversation

shashankhs11
Copy link
Contributor

@shashankhs11 shashankhs11 commented Aug 20, 2025

This is PR-2 to incrementally remove old code and builds upon #20378

Changes Made:

  • Updates constructor parameters of ActiveTaskCreator and StandbyTaskCreator
  • Updates the related tests

Checklist

@github-actions github-actions bot added triage PRs from the community streams small Small PRs labels Aug 20, 2025
@@ -204,7 +204,7 @@ public void initializeStartupTasks(final TopologyMetadata topologyMetadata,
if (hasPersistentStores && !nonEmptyTaskDirectories.isEmpty()) {
final ThreadCache dummyCache = new ThreadCache(logContext, 0, streamsMetrics);
final boolean eosEnabled = StreamsConfigUtils.eosEnabled(config);
final boolean stateUpdaterEnabled = StreamsConfig.InternalConfig.stateUpdaterEnabled(config.originals());
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It seems we pass this into ProcessorStateManager only -- let's move the variable, and hardcode true for now.

@@ -236,7 +235,7 @@ public StoreChangelogReader(final Time time,
this.stateRestoreListener = stateRestoreListener;
this.standbyUpdateListener = standbyUpdateListener;

this.stateUpdaterEnabled = InternalConfig.stateUpdaterEnabled(config.originals());
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think we only use this in one place, and it should be possible to remove the variable (and it's usage) completely, in one go

@@ -393,7 +393,7 @@ public static StreamThread create(final TopologyMetadata topologyMetadata,
final Runnable shutdownErrorHook,
final BiConsumer<Throwable, Boolean> streamsUncaughtExceptionHandler) {

final boolean stateUpdaterEnabled = InternalConfig.stateUpdaterEnabled(config.originals());
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This class is more complex. Might be better to split into a different PR, as it required more cleanup. Doing a partial cleanup for a single class, is not a "clean cut" and make reviewing more complex.

@@ -416,6 +417,7 @@ public void shouldPollWithRightTimeoutWithStateUpdater(final Task.TaskType type)
shouldPollWithRightTimeout(true, type);
}

@Disabled
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I would not disable this test, but rather clean it up directly. Or exclude StoreChangelogReader from this PR.

@github-actions github-actions bot removed the triage PRs from the community label Aug 23, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants