The actual code coverage of rdkafka integration is poor, we should increase it and hopefully add some tests bootstrapping kafka on CI too