62
62
import java .util .Arrays ;
63
63
import java .util .List ;
64
64
import java .util .Properties ;
65
+ import java .util .Set ;
65
66
66
67
import static org .hamcrest .CoreMatchers .equalTo ;
67
68
import static org .hamcrest .CoreMatchers .hasItems ;
@@ -410,6 +411,8 @@ public void shouldCalculateCorrectOldValuesIfMaterializedEvenIfStateful() {
410
411
411
412
final KeyValueStore <String , Integer > keyValueStore = driver .getKeyValueStore (QUERYABLE_NAME );
412
413
assertThat (keyValueStore .get ("A" ), is (3 ));
414
+ assertThat (driver .getAllStateStores ().keySet (),
415
+ equalTo (Set .of (QUERYABLE_NAME , "KTABLE-AGGREGATE-STATE-STORE-0000000005" )));
413
416
}
414
417
415
418
@ Test
@@ -434,6 +437,8 @@ public void shouldCalculateCorrectOldValuesIfNotStatefulEvenIfNotMaterialized()
434
437
assertThat (output (), equalTo (Arrays .asList (new KeyValueTimestamp <>("A" , "1" , 5 ),
435
438
new KeyValueTimestamp <>("A" , "2" , 15 ),
436
439
new KeyValueTimestamp <>("A" , "3" , 15 ))));
440
+ assertThat (driver .getAllStateStores ().keySet (),
441
+ equalTo (Set .of ("inputTopic-STATE-STORE-0000000000" , "KTABLE-AGGREGATE-STATE-STORE-0000000005" )));
437
442
}
438
443
439
444
@ Test
@@ -460,6 +465,8 @@ public void shouldCalculateCorrectOldValuesIfNotStatefulEvenNotMaterializedNoQue
460
465
assertThat (output (), equalTo (Arrays .asList (new KeyValueTimestamp <>("A" , "1" , 5 ),
461
466
new KeyValueTimestamp <>("A" , "2" , 15 ),
462
467
new KeyValueTimestamp <>("A" , "3" , 15 ))));
468
+ assertThat (driver .getAllStateStores ().keySet (),
469
+ equalTo (Set .of ("inputTopic-STATE-STORE-0000000000" , "KTABLE-AGGREGATE-STATE-STORE-0000000005" )));
463
470
}
464
471
465
472
private ArrayList <KeyValueTimestamp <String , String >> output () {
0 commit comments