Skip to content

Commit 8a93093

Browse files
committed
Revert the typo fix in proceessingThreadsEnabled
It is actually breaking becuase it gets redefined in line 469
1 parent 3aaf34d commit 8a93093

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -442,7 +442,7 @@ public static StreamThread create(final TopologyMetadata topologyMetadata,
442442

443443
final ThreadCache cache = new ThreadCache(logContext, cacheSizeBytes, streamsMetrics);
444444

445-
final boolean processingThreadsEnabled = InternalConfig.processingThreadsEnabled(config.originals());
445+
final boolean proceessingThreadsEnabled = InternalConfig.processingThreadsEnabled(config.originals());
446446
final ActiveTaskCreator activeTaskCreator = new ActiveTaskCreator(
447447
topologyMetadata,
448448
config,
@@ -455,7 +455,7 @@ public static StreamThread create(final TopologyMetadata topologyMetadata,
455455
threadIdx,
456456
processId,
457457
logContext,
458-
processingThreadsEnabled
458+
proceessingThreadsEnabled
459459
);
460460
final StandbyTaskCreator standbyTaskCreator = new StandbyTaskCreator(
461461
topologyMetadata,

0 commit comments

Comments
 (0)