tool
/
atlas
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ATLAS-4319 : Code refactoring in kafka bridge #136

This commit is contained in:
Benedict Jin 2021-06-01 23:00:57 +08:00 committed by GitHub
parent 8f1bd684e4
commit ab23b99c50
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
addons/kafka-bridge/src/main/java/org/apache/atlas/kafka/bridge/KafkaBridge.java
View File

@ -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();
}
}
}
}