root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

cleanup

This commit is contained in:
Matthias J. Sax 2025-09-28 19:21:11 -07:00
parent ad1c7f1079
commit 590b04ca12
1 changed files with 1 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
streams/src/test/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java
View File

@ -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 @Test
public void innerJoinShouldPropagateNothingWhenOldAndNewFKIsNull() { public void innerJoinShouldPropagateNothingWhenOldAndNewFKIsNull() {
final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>(); final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>();
@ -349,7 +332,7 @@ public class SubscriptionSendProcessorSupplierTest {
} }
@Test @Test
public void innerJoinShouldPropagateNewRecordOfUnchangedFK() { public void innerJoinShouldPropagateUnchangedFKOnlyIfFKExistsInRightTable() {
final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>(); final MockInternalProcessorContext<String, SubscriptionWrapper<String>> context = new MockInternalProcessorContext<>();
innerJoinProcessor.init(context); innerJoinProcessor.init(context);
context.setRecordMetadata("topic", 0, 0); context.setRecordMetadata("topic", 0, 0);