@amnamazhar librdkafka has all the capabilities needed. It's only code in phprdkafka that is missing. There are examples I could point you to in librdkafka if you want to :) maybe you can give it a shot yourself :)
@steveb_gitlab I will checkout the test sample you mentioned. if you can point me to any other example that would be great!