Could you make sure you are starting the consumer pipeline first and make sure it's running before starting the producer?