apache · eduwercamacaro · Oct 22, 2025 · Oct 27, 2025
diff --git a/.../test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java b/.../test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java
@@ -281,6 +281,11 @@ public void shouldPassMetrics(final String topologyType, final String groupProto
         streamsApplicationProperties = props(groupProtocol);
         final Topology topology = topologyType.equals("simple") ? simpleTopology(false) : complexTopology();
 
+        shouldPassMetrics(topology, FIRST_INSTANCE_CLIENT);
+        shouldPassMetrics(topology, SECOND_INSTANCE_CLIENT);
+    }
+
+    private void shouldPassMetrics(final Topology topology, final int clientInstance) throws Exception {
         try (final KafkaStreams streams = new KafkaStreams(topology, streamsApplicationProperties)) {
             IntegrationTestUtils.startApplicationAndWaitUntilRunning(streams);
 
@@ -292,8 +297,8 @@ public void shouldPassMetrics(final String topologyType, final String groupProto
 
 
 
-            final List<MetricName> consumerPassedStreamThreadMetricNames = INTERCEPTING_CONSUMERS.get(FIRST_INSTANCE_CLIENT).passedMetrics().stream().map(KafkaMetric::metricName).toList();
-            final List<MetricName> adminPassedStreamClientMetricNames = INTERCEPTING_ADMIN_CLIENTS.get(FIRST_INSTANCE_CLIENT).passedMetrics.stream().map(KafkaMetric::metricName).toList();
+            final List<MetricName> consumerPassedStreamThreadMetricNames = INTERCEPTING_CONSUMERS.get(clientInstance).passedMetrics().stream().map(KafkaMetric::metricName).toList();
+            final List<MetricName> adminPassedStreamClientMetricNames = INTERCEPTING_ADMIN_CLIENTS.get(clientInstance).passedMetrics.stream().map(KafkaMetric::metricName).toList();
 
 
             assertEquals(streamsThreadMetrics.size(), consumerPassedStreamThreadMetricNames.size());

diff --git a/streams/rocksdb/my-store/000840.sst b/streams/rocksdb/my-store/000840.sst
diff --git a/streams/rocksdb/my-store/000841.sst b/streams/rocksdb/my-store/000841.sst
diff --git a/streams/rocksdb/my-store/000848.sst b/streams/rocksdb/my-store/000848.sst
diff --git a/streams/rocksdb/my-store/000851.log b/streams/rocksdb/my-store/000851.log
diff --git a/streams/rocksdb/my-store/000855.sst b/streams/rocksdb/my-store/000855.sst
diff --git a/streams/rocksdb/my-store/CURRENT b/streams/rocksdb/my-store/CURRENT
@@ -0,0 +1 @@
+MANIFEST-000852
diff --git a/streams/rocksdb/my-store/IDENTITY b/streams/rocksdb/my-store/IDENTITY
@@ -0,0 +1 @@
+7b84a3b9-3c9c-48be-8c17-824a92b86a98
diff --git a/streams/rocksdb/my-store/LOCK b/streams/rocksdb/my-store/LOCK
diff --git a/streams/rocksdb/my-store/LOG b/streams/rocksdb/my-store/LOG
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792011407 b/streams/rocksdb/my-store/LOG.old.1761323792011407
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792046501 b/streams/rocksdb/my-store/LOG.old.1761323792046501
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792077198 b/streams/rocksdb/my-store/LOG.old.1761323792077198
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792119146 b/streams/rocksdb/my-store/LOG.old.1761323792119146
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792157400 b/streams/rocksdb/my-store/LOG.old.1761323792157400
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792186608 b/streams/rocksdb/my-store/LOG.old.1761323792186608
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792220476 b/streams/rocksdb/my-store/LOG.old.1761323792220476
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792280519 b/streams/rocksdb/my-store/LOG.old.1761323792280519
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792307235 b/streams/rocksdb/my-store/LOG.old.1761323792307235
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792330690 b/streams/rocksdb/my-store/LOG.old.1761323792330690
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792365936 b/streams/rocksdb/my-store/LOG.old.1761323792365936
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792404121 b/streams/rocksdb/my-store/LOG.old.1761323792404121
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792440846 b/streams/rocksdb/my-store/LOG.old.1761323792440846
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792464592 b/streams/rocksdb/my-store/LOG.old.1761323792464592
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792499803 b/streams/rocksdb/my-store/LOG.old.1761323792499803
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792558712 b/streams/rocksdb/my-store/LOG.old.1761323792558712
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792582399 b/streams/rocksdb/my-store/LOG.old.1761323792582399
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792608813 b/streams/rocksdb/my-store/LOG.old.1761323792608813
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792632113 b/streams/rocksdb/my-store/LOG.old.1761323792632113
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792669559 b/streams/rocksdb/my-store/LOG.old.1761323792669559
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792703358 b/streams/rocksdb/my-store/LOG.old.1761323792703358
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792748619 b/streams/rocksdb/my-store/LOG.old.1761323792748619
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792775665 b/streams/rocksdb/my-store/LOG.old.1761323792775665
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792797977 b/streams/rocksdb/my-store/LOG.old.1761323792797977
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792832641 b/streams/rocksdb/my-store/LOG.old.1761323792832641
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792871278 b/streams/rocksdb/my-store/LOG.old.1761323792871278
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792908607 b/streams/rocksdb/my-store/LOG.old.1761323792908607
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792943763 b/streams/rocksdb/my-store/LOG.old.1761323792943763
diff --git a/streams/rocksdb/my-store/LOG.old.1761323792983512 b/streams/rocksdb/my-store/LOG.old.1761323792983512
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793017405 b/streams/rocksdb/my-store/LOG.old.1761323793017405
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793054607 b/streams/rocksdb/my-store/LOG.old.1761323793054607
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793088341 b/streams/rocksdb/my-store/LOG.old.1761323793088341
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793121349 b/streams/rocksdb/my-store/LOG.old.1761323793121349
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793152806 b/streams/rocksdb/my-store/LOG.old.1761323793152806
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793188814 b/streams/rocksdb/my-store/LOG.old.1761323793188814
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793223410 b/streams/rocksdb/my-store/LOG.old.1761323793223410
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793260326 b/streams/rocksdb/my-store/LOG.old.1761323793260326
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793283769 b/streams/rocksdb/my-store/LOG.old.1761323793283769
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793307469 b/streams/rocksdb/my-store/LOG.old.1761323793307469
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793374975 b/streams/rocksdb/my-store/LOG.old.1761323793374975
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793399618 b/streams/rocksdb/my-store/LOG.old.1761323793399618
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793423906 b/streams/rocksdb/my-store/LOG.old.1761323793423906
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793457220 b/streams/rocksdb/my-store/LOG.old.1761323793457220
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793495748 b/streams/rocksdb/my-store/LOG.old.1761323793495748
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793562578 b/streams/rocksdb/my-store/LOG.old.1761323793562578
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793588606 b/streams/rocksdb/my-store/LOG.old.1761323793588606
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793655601 b/streams/rocksdb/my-store/LOG.old.1761323793655601
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793678108 b/streams/rocksdb/my-store/LOG.old.1761323793678108
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793704379 b/streams/rocksdb/my-store/LOG.old.1761323793704379
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793739212 b/streams/rocksdb/my-store/LOG.old.1761323793739212
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793811243 b/streams/rocksdb/my-store/LOG.old.1761323793811243
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793838647 b/streams/rocksdb/my-store/LOG.old.1761323793838647
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793906202 b/streams/rocksdb/my-store/LOG.old.1761323793906202
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793931033 b/streams/rocksdb/my-store/LOG.old.1761323793931033
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793957198 b/streams/rocksdb/my-store/LOG.old.1761323793957198
diff --git a/streams/rocksdb/my-store/LOG.old.1761323793983860 b/streams/rocksdb/my-store/LOG.old.1761323793983860
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794008122 b/streams/rocksdb/my-store/LOG.old.1761323794008122
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794034255 b/streams/rocksdb/my-store/LOG.old.1761323794034255
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794072516 b/streams/rocksdb/my-store/LOG.old.1761323794072516
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794101292 b/streams/rocksdb/my-store/LOG.old.1761323794101292
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794165485 b/streams/rocksdb/my-store/LOG.old.1761323794165485
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794188031 b/streams/rocksdb/my-store/LOG.old.1761323794188031
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794214060 b/streams/rocksdb/my-store/LOG.old.1761323794214060
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794238118 b/streams/rocksdb/my-store/LOG.old.1761323794238118
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794262160 b/streams/rocksdb/my-store/LOG.old.1761323794262160
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794330657 b/streams/rocksdb/my-store/LOG.old.1761323794330657
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794356353 b/streams/rocksdb/my-store/LOG.old.1761323794356353
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794419717 b/streams/rocksdb/my-store/LOG.old.1761323794419717
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794450337 b/streams/rocksdb/my-store/LOG.old.1761323794450337
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794476574 b/streams/rocksdb/my-store/LOG.old.1761323794476574
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794501540 b/streams/rocksdb/my-store/LOG.old.1761323794501540
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794524838 b/streams/rocksdb/my-store/LOG.old.1761323794524838
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794548891 b/streams/rocksdb/my-store/LOG.old.1761323794548891
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794616306 b/streams/rocksdb/my-store/LOG.old.1761323794616306
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794641749 b/streams/rocksdb/my-store/LOG.old.1761323794641749
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794667884 b/streams/rocksdb/my-store/LOG.old.1761323794667884
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794694258 b/streams/rocksdb/my-store/LOG.old.1761323794694258
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794720822 b/streams/rocksdb/my-store/LOG.old.1761323794720822
diff --git a/streams/rocksdb/my-store/LOG.old.1761323794748068 b/streams/rocksdb/my-store/LOG.old.1761323794748068
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885026226 b/streams/rocksdb/my-store/LOG.old.1761323885026226
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885074665 b/streams/rocksdb/my-store/LOG.old.1761323885074665
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885108076 b/streams/rocksdb/my-store/LOG.old.1761323885108076
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885134334 b/streams/rocksdb/my-store/LOG.old.1761323885134334
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885172161 b/streams/rocksdb/my-store/LOG.old.1761323885172161
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885219794 b/streams/rocksdb/my-store/LOG.old.1761323885219794
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885243845 b/streams/rocksdb/my-store/LOG.old.1761323885243845
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885279190 b/streams/rocksdb/my-store/LOG.old.1761323885279190
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885315885 b/streams/rocksdb/my-store/LOG.old.1761323885315885
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885354261 b/streams/rocksdb/my-store/LOG.old.1761323885354261
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885379604 b/streams/rocksdb/my-store/LOG.old.1761323885379604
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885418996 b/streams/rocksdb/my-store/LOG.old.1761323885418996
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885444833 b/streams/rocksdb/my-store/LOG.old.1761323885444833
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885480664 b/streams/rocksdb/my-store/LOG.old.1761323885480664
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885505552 b/streams/rocksdb/my-store/LOG.old.1761323885505552
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885539132 b/streams/rocksdb/my-store/LOG.old.1761323885539132
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885586663 b/streams/rocksdb/my-store/LOG.old.1761323885586663
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885614112 b/streams/rocksdb/my-store/LOG.old.1761323885614112
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885641755 b/streams/rocksdb/my-store/LOG.old.1761323885641755
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885670093 b/streams/rocksdb/my-store/LOG.old.1761323885670093
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885705579 b/streams/rocksdb/my-store/LOG.old.1761323885705579
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885738586 b/streams/rocksdb/my-store/LOG.old.1761323885738586
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885783722 b/streams/rocksdb/my-store/LOG.old.1761323885783722
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885808728 b/streams/rocksdb/my-store/LOG.old.1761323885808728
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885832851 b/streams/rocksdb/my-store/LOG.old.1761323885832851
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885870708 b/streams/rocksdb/my-store/LOG.old.1761323885870708
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885907147 b/streams/rocksdb/my-store/LOG.old.1761323885907147
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885941452 b/streams/rocksdb/my-store/LOG.old.1761323885941452
diff --git a/streams/rocksdb/my-store/LOG.old.1761323885973554 b/streams/rocksdb/my-store/LOG.old.1761323885973554
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886013270 b/streams/rocksdb/my-store/LOG.old.1761323886013270
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886046625 b/streams/rocksdb/my-store/LOG.old.1761323886046625
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886084501 b/streams/rocksdb/my-store/LOG.old.1761323886084501
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886120566 b/streams/rocksdb/my-store/LOG.old.1761323886120566
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886162303 b/streams/rocksdb/my-store/LOG.old.1761323886162303
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886200538 b/streams/rocksdb/my-store/LOG.old.1761323886200538
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886240053 b/streams/rocksdb/my-store/LOG.old.1761323886240053
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886276399 b/streams/rocksdb/my-store/LOG.old.1761323886276399
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886310994 b/streams/rocksdb/my-store/LOG.old.1761323886310994
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886338722 b/streams/rocksdb/my-store/LOG.old.1761323886338722
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886366805 b/streams/rocksdb/my-store/LOG.old.1761323886366805
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886437685 b/streams/rocksdb/my-store/LOG.old.1761323886437685
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886465143 b/streams/rocksdb/my-store/LOG.old.1761323886465143
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886492674 b/streams/rocksdb/my-store/LOG.old.1761323886492674
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886530538 b/streams/rocksdb/my-store/LOG.old.1761323886530538
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886569207 b/streams/rocksdb/my-store/LOG.old.1761323886569207
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886637625 b/streams/rocksdb/my-store/LOG.old.1761323886637625
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886664587 b/streams/rocksdb/my-store/LOG.old.1761323886664587
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886744431 b/streams/rocksdb/my-store/LOG.old.1761323886744431
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886770910 b/streams/rocksdb/my-store/LOG.old.1761323886770910
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886800440 b/streams/rocksdb/my-store/LOG.old.1761323886800440
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886835992 b/streams/rocksdb/my-store/LOG.old.1761323886835992
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886910514 b/streams/rocksdb/my-store/LOG.old.1761323886910514
diff --git a/streams/rocksdb/my-store/LOG.old.1761323886936764 b/streams/rocksdb/my-store/LOG.old.1761323886936764
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887007025 b/streams/rocksdb/my-store/LOG.old.1761323887007025
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887032292 b/streams/rocksdb/my-store/LOG.old.1761323887032292
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887056625 b/streams/rocksdb/my-store/LOG.old.1761323887056625
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887081797 b/streams/rocksdb/my-store/LOG.old.1761323887081797
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887106420 b/streams/rocksdb/my-store/LOG.old.1761323887106420
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887132311 b/streams/rocksdb/my-store/LOG.old.1761323887132311
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887168673 b/streams/rocksdb/my-store/LOG.old.1761323887168673
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887194513 b/streams/rocksdb/my-store/LOG.old.1761323887194513
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887261686 b/streams/rocksdb/my-store/LOG.old.1761323887261686
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887286410 b/streams/rocksdb/my-store/LOG.old.1761323887286410
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887309222 b/streams/rocksdb/my-store/LOG.old.1761323887309222
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887336666 b/streams/rocksdb/my-store/LOG.old.1761323887336666
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887362742 b/streams/rocksdb/my-store/LOG.old.1761323887362742
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887432782 b/streams/rocksdb/my-store/LOG.old.1761323887432782
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887458898 b/streams/rocksdb/my-store/LOG.old.1761323887458898
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887526859 b/streams/rocksdb/my-store/LOG.old.1761323887526859
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887552826 b/streams/rocksdb/my-store/LOG.old.1761323887552826
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887578854 b/streams/rocksdb/my-store/LOG.old.1761323887578854
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887604642 b/streams/rocksdb/my-store/LOG.old.1761323887604642
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887631684 b/streams/rocksdb/my-store/LOG.old.1761323887631684
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887659683 b/streams/rocksdb/my-store/LOG.old.1761323887659683
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887737835 b/streams/rocksdb/my-store/LOG.old.1761323887737835
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887764946 b/streams/rocksdb/my-store/LOG.old.1761323887764946
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887792621 b/streams/rocksdb/my-store/LOG.old.1761323887792621
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887818140 b/streams/rocksdb/my-store/LOG.old.1761323887818140
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887845853 b/streams/rocksdb/my-store/LOG.old.1761323887845853
diff --git a/streams/rocksdb/my-store/LOG.old.1761323887872730 b/streams/rocksdb/my-store/LOG.old.1761323887872730
diff --git a/streams/rocksdb/my-store/LOG.old.1761324670955504 b/streams/rocksdb/my-store/LOG.old.1761324670955504
diff --git a/streams/rocksdb/my-store/LOG.old.1761324698515288 b/streams/rocksdb/my-store/LOG.old.1761324698515288
diff --git a/streams/rocksdb/my-store/LOG.old.1761336584328259 b/streams/rocksdb/my-store/LOG.old.1761336584328259
diff --git a/streams/rocksdb/my-store/LOG.old.1761336681465458 b/streams/rocksdb/my-store/LOG.old.1761336681465458
diff --git a/streams/rocksdb/my-store/MANIFEST-000852 b/streams/rocksdb/my-store/MANIFEST-000852
diff --git a/streams/rocksdb/my-store/OPTIONS-000847 b/streams/rocksdb/my-store/OPTIONS-000847
@@ -0,0 +1,215 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+  rocksdb_version=10.1.3
+  options_file_version=1.1
+
+[DBOptions]
+  max_background_flushes=-1
+  compaction_readahead_size=2097152
+  strict_bytes_per_sync=false
+  wal_bytes_per_sync=0
+  max_open_files=-1
+  stats_history_buffer_size=1048576
+  max_total_wal_size=0
+  stats_persist_period_sec=600
+  stats_dump_period_sec=600
+  avoid_flush_during_shutdown=false
+  max_subcompactions=1
+  bytes_per_sync=0
+  delayed_write_rate=16777216
+  max_background_compactions=-1
+  max_background_jobs=14
+  delete_obsolete_files_period_micros=21600000000
+  writable_file_max_buffer_size=1048576
+  follower_catchup_retry_wait_ms=100
+  file_checksum_gen_factory=nullptr
+  allow_data_in_errors=false
+  max_bgerror_resume_count=2147483647
+  best_efforts_recovery=false
+  wal_write_temperature=kUnknown
+  write_identity_file=true
+  write_dbid_to_manifest=true
+  atomic_flush=false
+  manual_wal_flush=false
+  two_write_queues=false
+  avoid_flush_during_recovery=false
+  dump_malloc_stats=false
+  info_log_level=ERROR_LEVEL
+  write_thread_slow_yield_usec=3
+  unordered_write=false
+  follower_refresh_catchup_period_ms=10000
+  log_readahead_size=0
+  enable_pipelined_write=false
+  allow_ingest_behind=false
+  fail_if_options_file_error=true
+  persist_stats_to_disk=false
+  WAL_ttl_seconds=0
+  bgerror_resume_retry_interval=1000000
+  allow_concurrent_memtable_write=true
+  paranoid_checks=true
+  WAL_size_limit_MB=0
+  metadata_write_temperature=kUnknown
+  lowest_used_cache_tier=kNonVolatileBlockTier
+  keep_log_file_num=1000
+  table_cache_numshardbits=6
+  max_file_opening_threads=16
+  background_close_inactive_wals=false
+  wal_recovery_mode=kPointInTimeRecovery
+  follower_catchup_retry_count=10
+  db_write_buffer_size=0
+  allow_2pc=false
+  skip_checking_sst_file_sizes_on_db_open=false
+  skip_stats_update_on_db_open=false
+  recycle_log_file_num=0
+  db_host_id=__hostname__
+  track_and_verify_wals_in_manifest=false
+  use_fsync=false
+  wal_compression=kNoCompression
+  compaction_verify_record_count=true
+  error_if_exists=false
+  manifest_preallocation_size=4194304
+  is_fd_close_on_exec=true
+  enable_write_thread_adaptive_yield=true
+  track_and_verify_wals=false
+  enable_thread_tracking=false
+  avoid_unnecessary_blocking_io=false
+  allow_fallocate=true
+  max_log_file_size=0
+  advise_random_on_open=true
+  create_missing_column_families=false
+  max_write_batch_group_size_bytes=1048576
+  use_adaptive_mutex=false
+  prefix_seek_opt_in_only=false
+  wal_filter=nullptr
+  create_if_missing=true
+  enforce_single_del_contracts=true
+  allow_mmap_writes=false
+  verify_sst_unique_id_in_manifest=true
+  log_file_time_to_roll=0
+  use_direct_io_for_flush_and_compaction=false
+  flush_verify_memtable_count=true
+  max_manifest_file_size=1073741824
+  write_thread_max_yield_usec=100
+  use_direct_reads=false
+  allow_mmap_reads=false
+
+
+[CFOptions "default"]
+  bottommost_file_compaction_delay=0
+  memtable_protection_bytes_per_key=0
+  bottommost_compression=kDisableCompressionOption
+  sample_for_compression=0
+  blob_compression_type=kNoCompression
+  paranoid_memory_checks=false
+  blob_garbage_collection_age_cutoff=0.250000
+  preclude_last_level_data_seconds=0
+  compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;max_read_amp=-1;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;incremental=false;max_merge_width=4294967295;size_ratio=1;}
+  target_file_size_base=67108864
+  memtable_whole_key_filtering=false
+  blob_file_starting_level=0
+  soft_pending_compaction_bytes_limit=68719476736
+  max_write_buffer_number=3
+  ttl=2592000
+  compaction_options_fifo={file_temperature_age_thresholds=;allow_compaction=false;age_for_warm=0;max_table_files_size=1073741824;}
+  memtable_huge_page_size=0
+  max_sequential_skip_in_iterations=8
+  strict_max_successive_merges=false
+  max_successive_merges=0
+  enable_blob_garbage_collection=false
+  arena_block_size=1048576
+  bottommost_compression_opts={use_zstd_dict_trainer=true;enabled=false;zstd_max_train_bytes=0;parallel_threads=1;max_compressed_bytes_per_kb=896;checksum=false;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+  target_file_size_multiplier=1
+  max_bytes_for_level_multiplier_additional=1:1:1:1:1:1:1
+  prepopulate_blob_cache=kDisable
+  blob_compaction_readahead_size=0
+  min_blob_size=0
+  level0_stop_writes_trigger=36
+  blob_garbage_collection_force_threshold=1.000000
+  enable_blob_files=false
+  level0_slowdown_writes_trigger=20
+  default_write_temperature=kUnknown
+  compression=kNoCompression
+  level0_file_num_compaction_trigger=4
+  block_protection_bytes_per_key=0
+  prefix_extractor=nullptr
+  max_bytes_for_level_multiplier=10.000000
+  write_buffer_size=16777216
+  uncache_aggressiveness=0
+  disable_auto_compactions=false
+  max_compaction_bytes=1677721600
+  inplace_update_num_locks=10000
+  periodic_compaction_seconds=2592000
+  experimental_mempurge_threshold=0.000000
+  memtable_prefix_bloom_size_ratio=0.000000
+  max_bytes_for_level_base=268435456
+  paranoid_file_checks=false
+  blob_file_size=268435456
+  preserve_internal_time_seconds=0
+  memtable_max_range_deletions=0
+  compression_opts={use_zstd_dict_trainer=true;enabled=false;zstd_max_train_bytes=0;parallel_threads=1;max_compressed_bytes_per_kb=896;checksum=false;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+  hard_pending_compaction_bytes_limit=274877906944
+  last_level_temperature=kUnknown
+  table_factory=BlockBasedTable
+  report_bg_io_stats=false
+  persist_user_defined_timestamps=true
+  sst_partitioner_factory=nullptr
+  compaction_pri=kMinOverlappingRatio
+  compaction_style=kCompactionStyleUniversal
+  memtable_factory=SkipListFactory
+  comparator=leveldb.BytewiseComparator
+  bloom_locality=0
+  compaction_filter_factory=nullptr
+  min_write_buffer_number_to_merge=1
+  max_write_buffer_size_to_maintain=0
+  max_write_buffer_number_to_maintain=0
+  compaction_filter=nullptr
+  optimize_filters_for_hits=true
+  default_temperature=kUnknown
+  force_consistency_checks=true
+  merge_operator=nullptr
+  num_levels=7
+  memtable_insert_with_hint_prefix_extractor=nullptr
+  level_compaction_dynamic_level_bytes=false
+  disallow_memtable_writes=false
+  inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+  num_file_reads_for_auto_readahead=2
+  metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+  read_amp_bytes_per_bit=0
+  verify_compression=false
+  format_version=6
+  detect_filter_construct_corruption=false
+  optimize_filters_for_memory=true
+  decouple_partitioned_filters=false
+  partition_filters=false
+  initial_auto_readahead_size=8192
+  max_auto_readahead_size=262144
+  enable_index_compression=true
+  checksum=kXXH3
+  index_block_restart_interval=1
+  pin_top_level_index_and_filter=true
+  block_align=false
+  block_size=4096
+  index_type=kBinarySearch
+  filter_policy=bloomfilter:10:false
+  metadata_block_size=4096
+  no_block_cache=false
+  whole_key_filtering=true
+  index_shortening=kShortenSeparators
+  block_size_deviation=10
+  data_block_index_type=kDataBlockBinarySearch
+  use_delta_encoding=true
+  data_block_hash_table_util_ratio=0.750000
+  cache_index_and_filter_blocks=false
+  prepopulate_block_cache=kDisable
+  block_restart_interval=16
+  pin_l0_filter_and_index_blocks_in_cache=false
+  cache_index_and_filter_blocks_with_high_priority=true
+  flush_block_policy_factory=FlushBlockBySizePolicyFactory
+