fixes race condition
fixes race condition

fsaintjacques/kfc,fsaintjacques/kfc,slimhazard/kafkacat,slimhazard/kafkacat,pugna0/kafkacat,yiliaofan/kafkacat,imcom/kafkacat,haguenau/kfc,imcom/kafkacat,wikimedia/operations-debs-kafkacat,wikimedia/operations-debs-kafkacat,pugna0/kafkacat,haguenau/kfc,yiliaofan/kafkacat