You should add either use $conf->set('enable.auto.commit', 'true') or change from using RdKafka\Consumer to RdKafka\KafkaConsumer in order to be able to manually commit each message.

You are currently using RdKafka\Consumer, which does not have a commit() function.