Skip to content

Commit 9760783

Browse files
committed
Add env POLYCENTRIC_KAFKA_BROKER_ADDRESS_FAMILY to set broker.address.family
1 parent 344385f commit 9760783

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

services/common/kafka/src/config.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,10 @@ pub(crate) fn set_defaults(config: &mut ClientConfig) {
2525
.set(
2626
"sasl.password",
2727
env::var("POLYCENTRIC_KAFKA_SASL_PASSWORD").unwrap_or_default(),
28+
)
29+
.set(
30+
"broker.address.family",
31+
env::var("POLYCENTRIC_KAFKA_BROKER_ADDRESS_FAMILY")
32+
.unwrap_or_else(|_| "any".to_string()),
2833
);
2934
}

0 commit comments

Comments
 (0)