more

apache · Jan 23, 2025 · aef4458 · aef4458
1 parent cd7ec87
commit aef4458
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/.../src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java b/.../src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java
@@ -515,8 +515,6 @@ public void localSessionStoreShouldNotAllowInitOrClose() {
 
     @Test
     public void shouldNotSendRecordHeadersToChangelogTopic() {
-//        foreachSetUp();
-
         when(stateManager.taskType()).thenReturn(TaskType.ACTIVE);
         when(stateManager.registeredChangelogPartitionFor(REGISTERED_STORE_NAME)).thenReturn(CHANGELOG_PARTITION);
 
@@ -695,8 +693,6 @@ public void shouldThrowUnsupportedOperationExceptionOnRecordContext() {
 
     @Test
     public void shouldMatchStreamTime() {
-//        foreachSetUp();
-
         when(stateManager.taskType()).thenReturn(TaskType.ACTIVE);
 
         context = buildProcessorContextImpl(streamsConfig, stateManager);
@@ -733,8 +729,6 @@ public void shouldAddAndGetProcessorKeyValue() {
 
     @Test
     public void shouldSetAndGetProcessorMetaData() {
-//        foreachSetUp();
-
         context = buildProcessorContextImpl(streamsConfig, stateManager);
 
         mockProcessorNodeWithLocalKeyValueStore();