yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-04 12:51:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename elasticsearch-index to mae-consumer in MaeStreamTask

Browse Source
This commit is contained in:
Kerem Sahin 2019-12-19 17:46:19 -08:00
parent 2b867f8c5f
commit 6c99764fb1
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -102,8 +102,8 @@ public class MaeStreamTask {
final Properties streamsConfiguration = new Properties();
// Give the Streams application a unique name. The name must be unique in the Kafka cluster
// against which the application is run.
streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "elasticsearch-indexing-job");
streamsConfiguration.put(StreamsConfig.CLIENT_ID_CONFIG, "elasticsearch-indexing-job-client");
streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "mae-consumer-job");
streamsConfiguration.put(StreamsConfig.CLIENT_ID_CONFIG, "mae-consumer-job-client");
// Where to find Kafka broker(s).
streamsConfiguration.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG,
Configuration.getEnvironmentVariable("KAFKA_BOOTSTRAP_SERVER", DEFAULT_KAFKA_BOOTSTRAP_SERVER));