On Thu, Jul 13, 2017 at 6:44 AM, Polina Koleva <polina.n.koleva(a)gmail.com>
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