DBZ-3444 Upgrading to Apache Kafka 2.8
This commit is contained in:
parent
c980e519a3
commit
c2b13037fb
@ -216,7 +216,7 @@ public synchronized KafkaServer startup() {
|
|||||||
try {
|
try {
|
||||||
LOGGER.debug("Starting Kafka broker {} at {} with storage in {}", brokerId, getConnection(), logsDir.getAbsolutePath());
|
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),
|
server = new kafka.server.KafkaServer(new KafkaConfig(config), Time.SYSTEM, scala.Option.apply(null),
|
||||||
new scala.collection.mutable.ArraySeq<>(0));
|
false);
|
||||||
server.startup();
|
server.startup();
|
||||||
LOGGER.info("Started Kafka server {} at {} with storage in {}", brokerId, getConnection(), logsDir.getAbsolutePath());
|
LOGGER.info("Started Kafka server {} at {} with storage in {}", brokerId, getConnection(), logsDir.getAbsolutePath());
|
||||||
adminZkClient = new AdminZkClient(server.zkClient());
|
adminZkClient = new AdminZkClient(server.zkClient());
|
||||||
@ -309,7 +309,7 @@ public void createTopics(int numPartitions, int replicationFactor, String... top
|
|||||||
*/
|
*/
|
||||||
public void createTopic(String topic, int numPartitions, int replicationFactor) {
|
public void createTopic(String topic, int numPartitions, int replicationFactor) {
|
||||||
RackAwareMode rackAwareMode = null;
|
RackAwareMode rackAwareMode = null;
|
||||||
getAdminZkClient().createTopic(topic, numPartitions, replicationFactor, new Properties(), rackAwareMode);
|
getAdminZkClient().createTopic(topic, numPartitions, replicationFactor, new Properties(), rackAwareMode, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
4
pom.xml
4
pom.xml
@ -89,8 +89,8 @@
|
|||||||
<release.endpoint>https://s01.oss.sonatype.org/</release.endpoint>
|
<release.endpoint>https://s01.oss.sonatype.org/</release.endpoint>
|
||||||
|
|
||||||
<!-- Kafka and it's dependencies MUST reflect what the Kafka version uses -->
|
<!-- Kafka and it's dependencies MUST reflect what the Kafka version uses -->
|
||||||
<version.kafka>2.7.0</version.kafka>
|
<version.kafka>2.8.0</version.kafka>
|
||||||
<version.zookeeper>3.5.8</version.zookeeper>
|
<version.zookeeper>3.5.9</version.zookeeper>
|
||||||
<version.jackson>2.10.5</version.jackson>
|
<version.jackson>2.10.5</version.jackson>
|
||||||
<version.org.slf4j>1.7.30</version.org.slf4j>
|
<version.org.slf4j>1.7.30</version.org.slf4j>
|
||||||
<version.log4j>1.2.17</version.log4j>
|
<version.log4j>1.2.17</version.log4j>
|
||||||
|
Loading…
Reference in New Issue
Block a user