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

MongoDbConnector returns obsolete config values during validation

    XMLWordPrintable

Details

    Description

      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

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: