[aerogear-dev] Problems when injecting a Kafka Consumer

[Polina Koleva]

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
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/aerogear-dev/attachments/20170713/9b33f331/attachment.html