Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-7909

RabbitMQ Native Stream: Configuration is not being used

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Major Major
    • under-triaging
    • None
    • debezium-server
    • None
    • False
    • None
    • False

      Version used: 2.7.2.Final (Server Standalone)

      Hello,

      The documentation for the RabbitMQ Native Stream lets you believe that there is a wildcard connection config that can be used but in fact, it does nothing.

      The RabbitMQ Stream Java Client uses the environment builder to configure itself (https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#configuring-the-environment) but the Debezium Client is only configured to use the host and port parameter only which is very limiting and borders on unusable.

      As you can see in the codebase here: https://github.com/debezium/debezium-server/blob/main/debezium-server-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java#L75, the configProperties is being built properly but only 2 attributes are being used, leaving a lot of configuration on the table (see the first link).

      I think we should introduce a new wildcard "debezium.sink.rabbitmqstream.environment.*" that let you define more than just host and port. An important missing configuration option is username, password, virtualHost.

            Unassigned Unassigned
            zikphil Philippe Labat (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated: