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

MongoDbConnector returns obsolete config values during validation

XMLWordPrintable

      MongoDbConnectorConfig uses obsolete config parameters (DATABASE_LIST_NAME) in dependencies:

      public static final Field HOSTS = Field.create("mongodb.hosts")
                                             .withDisplayName("Hosts")
                                             .withType(Type.LIST)
                                             .withWidth(Width.LONG)
                                             .withImportance(Importance.HIGH)
                                             .withDependents(DATABASE_LIST_NAME)
                                             .withValidation(MongoDbConnectorConfig::validateHosts)
                                             .withDescription("The hostname and port pairs (in the form 'host' or 'host:port') "
                                                     + "of the MongoDB server(s) in the replica set.");
      
      public static final Field USER = Field.create("mongodb.user")
                                            .withDisplayName("User")
                                            .withType(Type.STRING)
                                            .withWidth(Width.SHORT)
                                            .withImportance(Importance.HIGH)
                                            .withDependents(DATABASE_LIST_NAME)
                                            .withDescription("Database user for connecting to MongoDB, if necessary.");
      
      public static final Field PASSWORD = Field.create("mongodb.password")
                                                .withDisplayName("Password")
                                                .withType(Type.PASSWORD)
                                                .withWidth(Width.SHORT)
                                                .withImportance(Importance.HIGH)
                                                .withDependents(DATABASE_LIST_NAME)
                                                .withDescription("Password to be used when connecting to MongoDB, if necessary.");
      

      This leads to the fact that MongoDbConnector returns the obsolete config values during validation (Config validate(Map<String, String> connectorConfigs)).

      The config parameter DATABASE_LIST_NAME was deleted in ticket DBZ-302 (https://github.com/debezium/debezium/pull/253).

      https://issues.apache.org/jira/browse/KAFKA-7407

            andrey.pustovetov@gmail.com Andrey Pustovetov
            andrey.pustovetov@gmail.com Andrey Pustovetov
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: