Explicitly close the temporary kafka consumer in get_offsets

used to retrieve partitions and lo/hi offets.

It could cause some dead-lock/long timeout kind of situation sometime
(especially in the developper docker environment).