ATLAS-4059 rename the config flag for enabling internal kafka topic import
Signed-off-by: Ashutosh Mestry <amestry@cloudera.com>
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 @@
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";