DBZ-2411 Use Scala 2.12
This commit is contained in:
parent
391d086529
commit
0b95df28d5
@ -20,7 +20,6 @@
|
||||
|
||||
import kafka.admin.RackAwareMode;
|
||||
import kafka.log.Log;
|
||||
import kafka.metrics.KafkaMetricsReporter;
|
||||
import kafka.server.KafkaConfig;
|
||||
import kafka.zk.AdminZkClient;
|
||||
import scala.collection.JavaConverters;
|
||||
@ -217,7 +216,7 @@ public synchronized KafkaServer startup() {
|
||||
try {
|
||||
LOGGER.debug("Starting Kafka broker {} at {} with storage in {}", brokerId, getConnection(), logsDir.getAbsolutePath());
|
||||
server = new kafka.server.KafkaServer(new KafkaConfig(config), Time.SYSTEM, scala.Option.apply(null),
|
||||
new scala.collection.mutable.ArraySeq.ofRef<>(new KafkaMetricsReporter[0]));
|
||||
new scala.collection.mutable.ArraySeq<>(0));
|
||||
server.startup();
|
||||
LOGGER.info("Started Kafka server {} at {} with storage in {}", brokerId, getConnection(), logsDir.getAbsolutePath());
|
||||
adminZkClient = new AdminZkClient(server.zkClient());
|
||||
|
2
pom.xml
2
pom.xml
@ -57,7 +57,7 @@
|
||||
|
||||
<!-- Kafka and it's dependencies MUST reflect what the Kafka version uses -->
|
||||
<version.kafka>2.6.0</version.kafka>
|
||||
<version.kafka.scala>2.13</version.kafka.scala>
|
||||
<version.kafka.scala>2.12</version.kafka.scala>
|
||||
<version.curator>4.2.0</version.curator>
|
||||
<version.zookeeper>3.5.8</version.zookeeper>
|
||||
<version.jackson>2.10.2</version.jackson>
|
||||
|
Loading…
Reference in New Issue
Block a user