offsetsStore() does not work when using 'connection string' in >=2.16 version

[lcialon]

Environment Information

• OS: Alpine 3.17
• Node Version: 18.14.0
• NPM Version: 9.6.7
• node-rdkafka version: >=2.16

It seems that since version 2.16, which includes the new version of librdkafka, the functionality of manually committing the offset when connecting to the event hub using connection string has stopped working. Version 2.15 is working properly.

Configuration:

'enable.auto.commit': true,
'enable.auto.offset.store': false

Code:

const processedTopicPartition = {
  topic,
  partition,
  offset
}
stream.consumer.offsetsStore([processedTopicPartition])

I checked, also, that offset_commit_cb is not called in this case.