diff --git a/src/Services/Implementations/ConfigurationService.cs b/src/Services/Implementations/ConfigurationService.cs index 713dc5e..4a166b3 100644 --- a/src/Services/Implementations/ConfigurationService.cs +++ b/src/Services/Implementations/ConfigurationService.cs @@ -23,8 +23,8 @@ public ConfigurationService(IConfiguration configuration) public long MessageConsumeLimitPerTopicPartition => GetValue("MessageConsumeLimitPerTopicPartition") ?? Int64.MaxValue; - public bool? EnableAutoCommit => GetValue("EnableAutoCommit"); - public bool? EnableAutoOffsetStore => GetValue("EnableAutoOffsetStore"); + public bool? EnableAutoCommit => GetValue("EnableAutoCommit") ?? false; + public bool? EnableAutoOffsetStore => GetValue("EnableAutoOffsetStore") ?? false; public string GroupId => GetValueOrThrowInvalidConfigException("GroupId"); public string SaslUsername => GetValue("SaslUsername"); public string SaslPassword => GetValue("SaslPassword");