From 6c99764fb1ef76a83c12cf82c6c20b4ff2a433cc Mon Sep 17 00:00:00 2001 From: Kerem Sahin Date: Thu, 19 Dec 2019 17:46:19 -0800 Subject: [PATCH] Rename elasticsearch-index to mae-consumer in MaeStreamTask --- .../main/java/com/linkedin/metadata/kafka/MaeStreamTask.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/MaeStreamTask.java b/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/MaeStreamTask.java index 1b800858e2..01b7ab915e 100644 --- a/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/MaeStreamTask.java +++ b/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/MaeStreamTask.java @@ -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));