public KafkaConsumer < String , String > createStringConsumer ( Properties overrideConfig ) { return createConsumer ( new StringDeserializer ( ) , new StringDeserializer ( ) , overrideConfig ) ; }
Create a consumer that reads strings