[aerogear-dev] Problems when injecting a Kafka Consumer

[Matthias Wessendorf]

I think the library needs to be ptachted to tear down the injected consumer
when the server shuts down. There is a CDI lifecycle event for that.

AFK, so can't do much


HTH,
Matthias



On Thu, 13 Jul 2017 at 12:47, 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.
>
> 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

-- 
Sent from Gmail Mobile
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/aerogear-dev/attachments/20170714/1a76a387/attachment.html