Skip to content

[smallrye-reactive-messaging-pulsar] Wrong config used in log message SRMSG 19011 "Created consumer for channel" and SRMSG 19012 "Created producer for channel" #3154

@pawel-boguski-ds

Description

@pawel-boguski-ds

Wrong config is used in log message SRMSG 19011 (Created consumer for channel %s with schema '%s' and configuration: %s). The actual config used to build consumer is based on the 'conf' but updated with values from 'ic' (in configResolver.configure).

https://github.com/smallrye/smallrye-reactive-messaging/blob/4.28.0/smallrye-reactive-messaging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/PulsarIncomingChannel.java#L78

In result if for example dead letter policy is configured using channel properties (instead of consumer config - in this case it works fine) then the dead letter policy is not printed in the log even if it's actually in the consumer config.

Same issue for outgoing channel: https://github.com/smallrye/smallrye-reactive-messaging/blob/4.28.0/smallrye-reactive-messaging-pulsar/src/main/java/io/smallrye/reactive/messaging/pulsar/PulsarOutgoingChannel.java#L62

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions