Skip to content

Commit 9bc0502

Browse files
Merge pull request #41 from ahmetfurkankavraz/main
#35 backward compatibility for EnableAutoCommit and EnableAutoOffsetS…
2 parents 01e190f + 024059d commit 9bc0502

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/Services/Implementations/ConfigurationService.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@ public ConfigurationService(IConfiguration configuration)
2323

2424
public long MessageConsumeLimitPerTopicPartition => GetValue<long?>("MessageConsumeLimitPerTopicPartition") ?? Int64.MaxValue;
2525

26-
public bool? EnableAutoCommit => GetValue<bool?>("EnableAutoCommit");
27-
public bool? EnableAutoOffsetStore => GetValue<bool?>("EnableAutoOffsetStore");
26+
public bool? EnableAutoCommit => GetValue<bool?>("EnableAutoCommit") ?? false;
27+
public bool? EnableAutoOffsetStore => GetValue<bool?>("EnableAutoOffsetStore") ?? false;
2828
public string GroupId => GetValueOrThrowInvalidConfigException("GroupId");
2929
public string SaslUsername => GetValue<string>("SaslUsername");
3030
public string SaslPassword => GetValue<string>("SaslPassword");

0 commit comments

Comments
 (0)