smallrye-reactive-messaging-kafka: Emitter inject in SubscriberDecorator unable to connect emitter error about quarkus

[edeweerd1A]

Let me know if I need reporting this upstream to smallrye-reactive-messaging repository.

[quarkus-bot]

/cc @cescoffier (reactive-messaging), @ozangunalp (reactive-messaging)

[ozangunalp]

Thanks for the reproducer.

It is very easy to create cyclic bean dependencies with emitters and SubscriberDecorator, because decorators are called immediately after creation. I am actually surprised you didn't have the issue with the @Outgoing channel already.

Please use an indirection to access the Emitter you are calling in the SubscriberDecorator, for example a separate bean that'll provide the emitter to the decorator.

@ApplicationScoped
public class EmitterProvider {
    
  @Channel("channel-name")
  Emitter<byte[]> emitter;

  Emitter<byte[]> getEmitter() {
    return emitter;
  }

}

You're having the issue updating to 3.10 because now subscriber decorators are also called on outgoing channel created for the dead letter queue.

Hope this explains.

[edeweerd1A]

OK now I understand! And thanks for the suggestion.