From 590b04ca12c8a5dc23533c7a4c0ef943f9d86dd7 Mon Sep 17 00:00:00 2001
From: "Matthias J. Sax" <matthias@confluent.io>
Date: Sun, 28 Sep 2025 19:21:11 -0700
Subject: [PATCH] cleanup

---
 ...SubscriptionSendProcessorSupplierTest.java | 19 +------------------
 1 file changed, 1 insertion(+), 18 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java
index 8a8de8740f6..d49df2f5cfd 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java
@@ -284,23 +284,6 @@ public class SubscriptionSendProcessorSupplierTest {
         );
     }
 
-    @Test
-    public void innerJoinShouldNotDeleteOldAndPropagateNewFKForUnchangedFK() {
-        final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>();
-        innerJoinProcessor.init(context);
-        context.setRecordMetadata("topic", 0, 0);
-
-        final LeftValue leftRecordValue = new LeftValue(fk1);
-
-        innerJoinProcessor.process(new Record<>(pk, new Change<>(leftRecordValue, leftRecordValue), 0));
-
-        assertThat(context.forwarded().size(), is(1));
-        assertThat(
-            context.forwarded().get(0).record(),
-            is(new Record<>(fk1, new SubscriptionWrapper<>(hash(leftRecordValue), PROPAGATE_ONLY_IF_FK_VAL_AVAILABLE, pk, 0), 0))
-        );
-    }
-
     @Test
     public void innerJoinShouldPropagateNothingWhenOldAndNewFKIsNull() {
         final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>();
@@ -349,7 +332,7 @@ public class SubscriptionSendProcessorSupplierTest {
     }
 
     @Test
-    public void innerJoinShouldPropagateNewRecordOfUnchangedFK() {
+    public void innerJoinShouldPropagateUnchangedFKOnlyIfFKExistsInRightTable() {
         final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>();
         innerJoinProcessor.init(context);
         context.setRecordMetadata("topic", 0, 0);