diff --git a/gms/factories/src/main/java/com/linkedin/common/factory/KafkaEventProducerFactory.java b/gms/factories/src/main/java/com/linkedin/common/factory/KafkaEventProducerFactory.java index ad1d4febc6..56d2842dd3 100644 --- a/gms/factories/src/main/java/com/linkedin/common/factory/KafkaEventProducerFactory.java +++ b/gms/factories/src/main/java/com/linkedin/common/factory/KafkaEventProducerFactory.java @@ -18,7 +18,7 @@ import org.springframework.context.annotation.Configuration; @EnableConfigurationProperties(KafkaProperties.class) public class KafkaEventProducerFactory { - @Value("${KAFKA_BOOTSTRAP_SERVER}") + @Value("${KAFKA_BOOTSTRAP_SERVER:http://localhost:9092}") private String kafkaBootstrapServers; @Value("${KAFKA_SCHEMAREGISTRY_URL:http://localhost:8081}") diff --git a/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java b/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java index 901a117a7c..2b6e6e17b4 100644 --- a/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java +++ b/metadata-jobs/mae-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java @@ -20,7 +20,7 @@ import org.springframework.kafka.core.DefaultKafkaConsumerFactory; @Slf4j @Configuration public class KafkaConfig { - @Value("${KAFKA_BOOTSTRAP_SERVER}") + @Value("${KAFKA_BOOTSTRAP_SERVER:http://localhost:9092}") private String kafkaBootstrapServer; @Value("${KAFKA_SCHEMAREGISTRY_URL:http://localhost:8081}") private String kafkaSchemaRegistryUrl; diff --git a/metadata-jobs/mce-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java b/metadata-jobs/mce-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java index 7b0c0c068c..98e9e236a5 100644 --- a/metadata-jobs/mce-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java +++ b/metadata-jobs/mce-consumer-job/src/main/java/com/linkedin/metadata/kafka/config/KafkaConfig.java @@ -25,7 +25,7 @@ import org.springframework.kafka.listener.ErrorHandler; @Slf4j @Configuration public class KafkaConfig { - @Value("${KAFKA_BOOTSTRAP_SERVER}") + @Value("${KAFKA_BOOTSTRAP_SERVER:http://localhost:9092}") private String kafkaBootstrapServers; @Value("${KAFKA_SCHEMAREGISTRY_URL:http://localhost:8081}") private String kafkaSchemaRegistryUrl;