We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7b6ff63 commit 7c46f4cCopy full SHA for 7c46f4c
core/src/test/java/kafka/server/share/DelayedShareFetchTest.java
@@ -17,7 +17,6 @@
17
package kafka.server.share;
18
19
import kafka.cluster.Partition;
20
-import kafka.log.remote.RemoteLogManager;
21
import kafka.server.LogReadResult;
22
import kafka.server.QuotaFactory;
23
import kafka.server.ReplicaManager;
@@ -34,6 +33,7 @@
34
33
import org.apache.kafka.common.record.Records;
35
import org.apache.kafka.common.requests.FetchRequest;
36
import org.apache.kafka.common.utils.Time;
+import org.apache.kafka.server.log.remote.storage.RemoteLogManager;
37
import org.apache.kafka.server.purgatory.DelayedOperationKey;
38
import org.apache.kafka.server.purgatory.DelayedOperationPurgatory;
39
import org.apache.kafka.server.share.SharePartitionKey;
0 commit comments