Read and validate incoming sub create request from Kafka