You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by am...@apache.org on 2021/10/05 16:37:01 UTC
[atlas] branch master updated: ATLAS-4440: Update Kafka dependency
to 2.8.1
This is an automated email from the ASF dual-hosted git repository.
amestry pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push:
new 028e3e0 ATLAS-4440: Update Kafka dependency to 2.8.1
028e3e0 is described below
commit 028e3e0b85ee63619924a157f1bf790a2fd9f213
Author: Viktor Somogyi-Vass <vi...@gmail.com>
AuthorDate: Thu Sep 30 10:58:11 2021 +0200
ATLAS-4440: Update Kafka dependency to 2.8.1
Signed-off-by: Ashutosh Mestry <am...@cloudera.com>
---
.../src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java | 2 +-
pom.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/notification/src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java b/notification/src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java
index b793b9a..19717fb 100644
--- a/notification/src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java
+++ b/notification/src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java
@@ -136,7 +136,7 @@ public class EmbeddedKafkaServer implements Service {
brokerConfig.setProperty("log.dirs", constructDir("kafka").getAbsolutePath());
brokerConfig.setProperty("log.flush.interval.messages", String.valueOf(1));
- kafkaServer = new KafkaServer(KafkaConfig.fromProps(brokerConfig), Time.SYSTEM, Option.apply(this.getClass().getName()), new ArrayBuffer<>());
+ kafkaServer = new KafkaServer(KafkaConfig.fromProps(brokerConfig), Time.SYSTEM, Option.apply(this.getClass().getName()), false);
kafkaServer.startup();
diff --git a/pom.xml b/pom.xml
index 47768e9..7ccf0af 100644
--- a/pom.xml
+++ b/pom.xml
@@ -730,7 +730,7 @@
<jsr.version>1.1</jsr.version>
<junit.version>4.13.1</junit.version>
<kafka.scala.binary.version>2.12</kafka.scala.binary.version>
- <kafka.version>2.5.0</kafka.version>
+ <kafka.version>2.8.1</kafka.version>
<keycloak.version>6.0.1</keycloak.version>
<log4j.version>1.2.17</log4j.version>
<log4j2.version>2.13.3</log4j2.version>