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 2020/12/09 22:27:21 UTC

[atlas] 01/02: ATLAS-4059 rename the config flag for enabling internal kafka topic import

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

commit 8801ba6814abbd2c60c88d04cf1649efed2f3429
Author: Deep Singh <de...@gmail.com>
AuthorDate: Thu Dec 3 12:20:31 2020 -0600

    ATLAS-4059 rename the config flag for enabling internal kafka topic import
    
    Signed-off-by: Ashutosh Mestry <am...@cloudera.com>
---
 common/src/main/java/org/apache/atlas/utils/KafkaUtils.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/common/src/main/java/org/apache/atlas/utils/KafkaUtils.java b/common/src/main/java/org/apache/atlas/utils/KafkaUtils.java
index 7e9f789..14e205a 100644
--- a/common/src/main/java/org/apache/atlas/utils/KafkaUtils.java
+++ b/common/src/main/java/org/apache/atlas/utils/KafkaUtils.java
@@ -58,7 +58,7 @@ public class KafkaUtils implements AutoCloseable {
     private static final String JAAS_PRINCIPAL_PROP = "principal";
     private static final String JAAS_DEFAULT_CLIENT_NAME = "KafkaClient";
     private static final String JAAS_TICKET_BASED_CLIENT_NAME = "ticketBased-KafkaClient";
-    private static final String IMPORT_INTERNAL_TOPICS = "atlas.hook.kafka.import.internal.topics";
+    private static final String IMPORT_INTERNAL_TOPICS = "atlas.kafka.bridge.enable.internal.topics.import";
 
     public static final String ATLAS_KAFKA_PROPERTY_PREFIX   = "atlas.kafka";