Added more env vars that will be useful when scaling up producers and consumers, also improved the loading of messages by using camel dataset