-
Bug
-
Resolution: Unresolved
-
Major
-
None
-
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.