Skip to content

Commit 8aa0690

Browse files
committed
Workaround for scala/scala3#13572
1 parent 0c43f3e commit 8aa0690

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

core/src/main/java/kafka/server/builders/LogManagerBuilder.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
package kafka.server.builders;
1919

2020
import kafka.api.ApiVersion;
21+
import kafka.api.ApiVersion$;
2122
import kafka.log.CleanerConfig;
2223
import kafka.log.LogConfig;
2324
import kafka.log.LogManager;
@@ -45,7 +46,7 @@ public class LogManagerBuilder {
4546
private long flushStartOffsetCheckpointMs = 10000L;
4647
private long retentionCheckMs = 1000L;
4748
private int maxPidExpirationMs = 60000;
48-
private ApiVersion interBrokerProtocolVersion = ApiVersion.latestVersion();
49+
private ApiVersion interBrokerProtocolVersion = ApiVersion$.MODULE$.latestVersion();
4950
private Scheduler scheduler = null;
5051
private BrokerTopicStats brokerTopicStats = null;
5152
private LogDirFailureChannel logDirFailureChannel = null;

core/src/test/java/kafka/testkit/KafkaClusterTestKit.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import kafka.server.KafkaRaftServer;
2626
import kafka.server.MetaProperties;
2727
import kafka.server.Server;
28+
import kafka.server.Server$;
2829
import kafka.tools.StorageTool;
2930
import kafka.utils.Logging;
3031
import org.apache.kafka.clients.CommonClientConfigs;
@@ -234,7 +235,7 @@ metaProperties, config, new MetadataRecordSerde(), metadataPartition, KafkaRaftS
234235
Option.apply(threadNamePrefix),
235236
JavaConverters.asScalaBuffer(Collections.<String>emptyList()).toSeq(),
236237
connectFutureManager.future,
237-
Server.SUPPORTED_FEATURES()
238+
Server$.MODULE$.SUPPORTED_FEATURES()
238239
);
239240
brokers.put(node.id(), broker);
240241
raftManagers.put(node.id(), raftManager);

0 commit comments

Comments
 (0)