This is an automated email from the ASF dual-hosted git repository. nixon pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/atlas.git
commit 6e07c2e4fd1b0c4acf28781d021a989dfdbcbc1c Author: Benedict Jin <asdf2...@apache.org> AuthorDate: Tue Jun 1 23:00:57 2021 +0800 ATLAS-4319 : Code refactoring in kafka bridge #136 (cherry picked from commit ab23b99c50ec355773da35da2af5a2c3d01c3cec) --- .../src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/addons/kafka-bridge/src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java b/addons/kafka-bridge/src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java index bf74c67..f954824 100644 --- a/addons/kafka-bridge/src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java +++ b/addons/kafka-bridge/src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java @@ -70,7 +70,7 @@ public class KafkaBridge { private static final String URI = "uri"; private static final String CLUSTERNAME = "clusterName"; private static final String TOPIC = "topic"; - private static final String FORMAT_KAKFA_TOPIC_QUALIFIED_NAME = "%s@%s"; + private static final String FORMAT_KAFKA_TOPIC_QUALIFIED_NAME = "%s@%s"; private final List<String> availableTopics; private final String metadataNamespace; @@ -255,7 +255,7 @@ public class KafkaBridge { @VisibleForTesting static String getTopicQualifiedName(String metadataNamespace, String topic) { - return String.format(FORMAT_KAKFA_TOPIC_QUALIFIED_NAME, topic.toLowerCase(), metadataNamespace); + return String.format(FORMAT_KAFKA_TOPIC_QUALIFIED_NAME, topic.toLowerCase(), metadataNamespace); } private AtlasEntityWithExtInfo findTopicEntityInAtlas(String topicQualifiedName) { @@ -358,4 +358,4 @@ public class KafkaBridge { entity.getRelationshipAttributes().clear(); } } -} \ No newline at end of file +}