Changed codes for just one stream from kafka.