Kafka reader unit test is fixed