ATLAS-4059 rename the config flag for enabling internal kafka topic import

Signed-off-by: Ashutosh Mestry <amestry@cloudera.com>

ATLAS-4059 rename the config flag for enabling internal kafka topic import
8801ba68 · Deep Singh · Ashutosh Mestry · 294ca40d · 8801ba68
Commit 8801ba68 authored Dec 03, 2020 by Deep Singh Committed by Ashutosh Mestry Dec 09, 2020
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

KafkaUtils.java common/src/main/java/org/apache/atlas/utils/KafkaUtils.java +1 -1

No files found.
--- 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";