You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by ni...@apache.org on 2021/06/01 15:01:10 UTC
[atlas] branch master updated: ATLAS-4319 : Code refactoring in
kafka bridge #136
This is an automated email from the ASF dual-hosted git repository.
nixon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push:
new ab23b99 ATLAS-4319 : Code refactoring in kafka bridge #136
ab23b99 is described below
commit ab23b99c50ec355773da35da2af5a2c3d01c3cec
Author: Benedict Jin <as...@apache.org>
AuthorDate: Tue Jun 1 23:00:57 2021 +0800
ATLAS-4319 : Code refactoring in kafka bridge #136
---
.../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
+}