rebase

Signed-off-by: see-quick <maros.orsak159@gmail.com>

Author: see-quick

storage/src/test/java/org/apache/kafka/storage/internals/log/AbstractLogCleanerIntegrationTest.java

@@ -19,9 +19,9 @@
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.compress.Compression;
 import org.apache.kafka.common.config.TopicConfig;
-import org.apache.kafka.common.record.MemoryRecords;
-import org.apache.kafka.common.record.RecordBatch;
-import org.apache.kafka.common.record.RecordVersion;
+import org.apache.kafka.common.record.internal.MemoryRecords;
+import org.apache.kafka.common.record.internal.RecordBatch;
+import org.apache.kafka.common.record.internal.RecordVersion;
 import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.coordinator.transaction.TransactionLogConfig;
 import org.apache.kafka.server.util.MockTime;

storage/src/test/java/org/apache/kafka/storage/internals/log/LogCleanerLagIntegrationTest.java

@@ -18,8 +18,8 @@
 
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.compress.Compression;
-import org.apache.kafka.common.record.CompressionType;
-import org.apache.kafka.common.record.Record;
+import org.apache.kafka.common.record.internal.CompressionType;
+import org.apache.kafka.common.record.internal.Record;
 import org.apache.kafka.server.util.MockTime;
 
 import org.junit.jupiter.api.Tag;