<div dir="ltr">Hey, everyone :)<div>As we finished the initial integration of Kafka in UPS, we decided to use a <a href="https://github.com/matzew/kafka-cdi">CDI library</a> to ease the addition of new Kafka consumers/producers. Unfortunately, when I added a consumer by injection (<a href="https://github.com/polinankoleva/aerogear-unifiedpush-server/commit/27961bc29f3be817faaf845baa2893a32eeae3da">github commit</a>) I encountered three problems. I have tried to do my best to figure them out but I still have no clue for them. They all happen after a redeployment of the UPS, so I suppose there is a problem when a consumer is destroyed/created again. </div><div><br></div><div>You can find the problems described in JIRA. I really appreciate your help.</div><div><br></div><div>1. <a href="https://issues.jboss.org/browse/AGPUSH-2145">ComponentIsStoppedException</a></div><div>2. <a href="https://issues.jboss.org/browse/AGPUSH-2139">IllegalArgumentException: object is not an instance of declaring class</a></div><div>3. <a href="https://issues.jboss.org/browse/AGPUSH-2140">InstanceAlreadyExistsException</a> -  I suppose this happens because we never close the consumer. That&#39;s why I made a <a href="https://github.com/matzew/kafka-cdi/pull/12">pull request</a> with an addition of shutdown method for the consumer. But not sure where exactly this method has to be invoked. </div><div><br></div><div>Thanks, Polina</div></div>