[aerogear-dev] Problems when injecting a Kafka Consumer

[Summers Pittman]

On Thu, Jul 13, 2017 at 6:44 AM, Polina Koleva <polina.n.koleva at 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/27961bc29f3be817faaf845baa2893a32eeae3da>)
> 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 at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/aerogear-dev
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/aerogear-dev/attachments/20170717/6a7c5843/attachment.html