This was previously resolved by pull request #1669 however it was seemingly lost on https://github.com/dpkp/kafka-python/commit/f2f2bfe44d51b3474f955c16c30ab132f14ba551