-53661h -53661h -53637h -53635h -53635h -53635h -53598h -53489h -53488h -53486h
 
 
 
 
 
 
 
 
 
 
DirectKafkaStreamSuite: offset recovery from kafka