Skip to content

Commit 12020f5

Browse files
Fix: KafkaConsumer crashes with autoCommit=true (#102)
Motivation: Closes #99. Modifications: * `KafkaConsumer`: only subscribe to `RDKafkaEvent.offsetCommit` when `KakfaCOnsumerConfiguration.enableAutoCommit == false`
1 parent f8cb0a0 commit 12020f5

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

Sources/SwiftKafka/KafkaConsumer.swift

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,10 +121,16 @@ public final class KafkaConsumer: Sendable, Service {
121121
self.config = config
122122
self.logger = logger
123123

124+
var subscribedEvents: [RDKafkaEvent] = [.log, .fetch]
125+
// Only listen to offset commit events when autoCommit is false
126+
if self.config.enableAutoCommit == false {
127+
subscribedEvents.append(.offsetCommit)
128+
}
129+
124130
let client = try RDKafkaClient.makeClient(
125131
type: .consumer,
126132
configDictionary: config.dictionary,
127-
events: [.log, .fetch, .offsetCommit],
133+
events: subscribedEvents,
128134
logger: logger
129135
)
130136

0 commit comments

Comments
 (0)