(kafka) branch trunk updated: KAFKA-20553 Move RocksDBStoreTestingUtils to streams:integration-tests (#23017)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new fb2ffe201b8 KAFKA-20553 Move RocksDBStoreTestingUtils to 
streams:integration-tests (#23017)
fb2ffe201b8 is described below

commit fb2ffe201b825cdb1b8a955e9d1e1eda6823e9c8
Author: PoAn Yang <pay...@apache.org>
AuthorDate: Sun Aug 2 03:45:46 2026 +0900

    KAFKA-20553 Move RocksDBStoreTestingUtils to streams:integration-tests 
(#23017)
    
    Followup from
    https://github.com/apache/kafka/pull/22521#pullrequestreview-4829847611
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 build.gradle                                                          | 1 -
 checkstyle/import-control.xml                                         | 4 ++++
 .../integration/SelfManagedOffsetLifecycleIntegrationTest.java        | 2 +-
 .../streams/integration/SelfManagedOffsetRecoveryIntegrationTest.java | 2 +-
 .../kafka/streams/integration/utils}/RocksDBStoreTestingUtils.java    | 2 +-
 5 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/build.gradle b/build.gradle
index 4bb9c0980a9..2196dd339a7 100644
--- a/build.gradle
+++ b/build.gradle
@@ -3010,7 +3010,6 @@ project(':streams:streams-scala') {
     api project(':streams')
 
     api libs.scalaLibrary
-    testImplementation testFixtures(project(':streams'))
     testImplementation testFixtures(project(':clients'))
     testImplementation project(':streams:test-utils')
 
diff --git a/checkstyle/import-control.xml b/checkstyle/import-control.xml
index 3ca56f078c7..36dde497ff7 100644
--- a/checkstyle/import-control.xml
+++ b/checkstyle/import-control.xml
@@ -424,6 +424,10 @@
       <allow pkg="org.apache.kafka.coordinator.group" />
       <allow pkg="org.apache.kafka.network" />
       <allow pkg="org.apache.kafka.server.streams" />
+
+      <subpackage name="utils">
+        <allow pkg="org.rocksdb" />
+      </subpackage>
     </subpackage>
 
     <subpackage name="test">
diff --git 
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetLifecycleIntegrationTest.java
 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetLifecycleIntegrationTest.java
index d6a55bdb7ce..88b65123360 100644
--- 
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetLifecycleIntegrationTest.java
+++ 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetLifecycleIntegrationTest.java
@@ -32,6 +32,7 @@ import org.apache.kafka.streams.StreamsBuilder;
 import org.apache.kafka.streams.StreamsConfig;
 import org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster;
 import org.apache.kafka.streams.integration.utils.IntegrationTestUtils;
+import org.apache.kafka.streams.integration.utils.RocksDBStoreTestingUtils;
 import org.apache.kafka.streams.kstream.KStream;
 import org.apache.kafka.streams.kstream.Materialized;
 import org.apache.kafka.streams.processor.StateRestoreListener;
@@ -39,7 +40,6 @@ import 
org.apache.kafka.streams.processor.internals.ProcessorStateManager;
 import org.apache.kafka.streams.processor.internals.StateDirectory;
 import org.apache.kafka.streams.state.QueryableStoreTypes;
 import org.apache.kafka.streams.state.ReadOnlyKeyValueStore;
-import org.apache.kafka.streams.state.internals.RocksDBStoreTestingUtils;
 import org.apache.kafka.test.TestUtils;
 
 import org.junit.jupiter.api.AfterAll;
diff --git 
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetRecoveryIntegrationTest.java
 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetRecoveryIntegrationTest.java
index a9ac4b4059b..84e2f40c11d 100644
--- 
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetRecoveryIntegrationTest.java
+++ 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SelfManagedOffsetRecoveryIntegrationTest.java
@@ -31,10 +31,10 @@ import org.apache.kafka.streams.TaskMetadata;
 import org.apache.kafka.streams.ThreadMetadata;
 import org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster;
 import org.apache.kafka.streams.integration.utils.IntegrationTestUtils;
+import org.apache.kafka.streams.integration.utils.RocksDBStoreTestingUtils;
 import org.apache.kafka.streams.kstream.KStream;
 import org.apache.kafka.streams.kstream.Materialized;
 import org.apache.kafka.streams.kstream.Produced;
-import org.apache.kafka.streams.state.internals.RocksDBStoreTestingUtils;
 import org.apache.kafka.test.TestUtils;
 
 import org.junit.jupiter.api.AfterAll;
diff --git 
a/streams/src/testFixtures/java/org/apache/kafka/streams/state/internals/RocksDBStoreTestingUtils.java
 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/RocksDBStoreTestingUtils.java
similarity index 99%
rename from 
streams/src/testFixtures/java/org/apache/kafka/streams/state/internals/RocksDBStoreTestingUtils.java
rename to 
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/RocksDBStoreTestingUtils.java
index 79871b980c9..fc6170057ba 100644
--- 
a/streams/src/testFixtures/java/org/apache/kafka/streams/state/internals/RocksDBStoreTestingUtils.java
+++ 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/RocksDBStoreTestingUtils.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.kafka.streams.state.internals;
+package org.apache.kafka.streams.integration.utils;
 
 import org.apache.kafka.common.serialization.Serdes;
 import org.apache.kafka.common.serialization.StringSerializer;