yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-15 19:03:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename ElasticSearchStreamTask to MaeStreamTask

Browse Source
This commit is contained in:
Kerem Sahin 2019-11-20 18:22:54 -08:00
parent c64c5d384d
commit 22eefc966b
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
metadata-jobs/mae-consumer-job/build.gradle
View File

@ -42,4 +42,4 @@ clean {
project.delete("src/main/resources/avro") project.delete("src/main/resources/avro")
} }
mainClassName = 'com.linkedin.metadata.kafka.ElasticSearchStreamTask' mainClassName = 'com.linkedin.metadata.kafka.MaeStreamTask'

2
metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/ElasticSearchStreamTask.java → metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/MaeStreamTask.java
View File

@ -27,7 +27,7 @@ import java.net.URLEncoder;
import java.util.*; import java.util.*;
@Slf4j @Slf4j
public class ElasticSearchStreamTask { public class MaeStreamTask {
private static final String DOC_TYPE = "doc"; private static final String DOC_TYPE = "doc";
private static final String DEFAULT_KAFKA_TOPIC_NAME = Topics.METADATA_AUDIT_EVENT; private static final String DEFAULT_KAFKA_TOPIC_NAME = Topics.METADATA_AUDIT_EVENT;