Skip to content
This repository was archived by the owner on Feb 10, 2025. It is now read-only.

Commit 13847e8

Browse files
committed
sor get or default changes
1 parent 173f50b commit 13847e8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sor/src/main/java/com/bazaarvoice/emodb/sor/kafka/KafkaConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public class KafkaConfig {
5858
lingerMsConfig = parameterValues.getOrDefault("/" + UNIVERSE + "/emodb/kafka/lingerMs", "1");
5959

6060
// Configures the Kafka broker addresses for producer connections.
61-
bootstrapServersConfig = parameterValues.get("/" + UNIVERSE + "/emodb/kafka/bootstrapServers");
61+
bootstrapServersConfig = parameterValues.getOrDefault("/" + UNIVERSE + "/emodb/kafka/bootstrapServers", "localhost:9092");
6262

6363
logger.info("Kafka configurations loaded successfully from SSM.");
6464
} catch (AmazonServiceException e) {

0 commit comments

Comments
 (0)