Break out SubscribeKafkaTopic function.