This is an automated email from the ASF dual-hosted git repository. amestry pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/atlas.git
commit 41e83f13526540e7864b1c2b55b74dc9aca503e0 Author: Deep Singh <deepam1...@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 <ames...@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";