Hey, everyone :) As we finished the initial integration of Kafka in UPS, we decided to use a CDI library <https://github.com/matzew/kafka-cdi> to ease the addition of new Kafka consumers/producers. Unfortunately, when I added a consumer by injection (github commit <https://github.com/polinankoleva/aerogear-unifiedpush-server/commit/27961...>) 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. You can find the problems described in JIRA. I really appreciate your help. 1. ComponentIsStoppedException <https://issues.jboss.org/browse/AGPUSH-2145> 2. IllegalArgumentException: object is not an instance of declaring class <https://issues.jboss.org/browse/AGPUSH-2139> 3. InstanceAlreadyExistsException <https://issues.jboss.org/browse/AGPUSH-2140> - I suppose this happens because we never close the consumer. That's why I made a pull request <https://github.com/matzew/kafka-cdi/pull/12> with an addition of shutdown method for the consumer. But not sure where exactly this method has to be invoked. Thanks, Polina _______________________________________________ aerogear-dev mailing list aerogear-dev(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/aerogear-dev

On Thu, Jul 13, 2017 at 6:44 AM, Polina Koleva <polina.n.koleva(a)gmail.com&gt; wrote: > Hey, everyone :) > As we finished the initial integration of Kafka in UPS, we decided to use > a CDI library <https://github.com/matzew/kafka-cdi> to ease the addition > of new Kafka consumers/producers. Unfortunately, when I added a consumer by > injection (github commit > <https://github.com/polinankoleva/aerogear-unifiedpush-server/commit/27961...>) > 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. > So the problem occurs if you have a running Wildfly and if you redeploy to it, or if you shut down WildFly and the start it up with a new war(ie in a container)?

> > You can find the problems described in JIRA. I really appreciate your > help. > > 1. ComponentIsStoppedException > <https://issues.jboss.org/browse/AGPUSH-2145> > 2. IllegalArgumentException: object is not an instance of declaring class > <https://issues.jboss.org/browse/AGPUSH-2139> > 3. InstanceAlreadyExistsException > <https://issues.jboss.org/browse/AGPUSH-2140> - I suppose this happens > because we never close the consumer. That's why I made a pull request > <https://github.com/matzew/kafka-cdi/pull/12> with an addition of > shutdown method for the consumer. But not sure where exactly this method > has to be invoked. > > Thanks, Polina > > _______________________________________________ > aerogear-dev mailing list > aerogear-dev(a)lists.jboss.org > https://lists.jboss.org/mailman/listinfo/aerogear-dev > _______________________________________________ aerogear-dev mailing list aerogear-dev(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/aerogear-dev