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

2.7.0.Alpha2 snapshot.locking.mode: "none" throws error

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Not a Bug
    • Icon: Major Major
    • None
    • None
    • core-library
    • None
    • False
    • None
    • False
    • Critical

      In 2.7.0.Alpha2, even when `snapshot.locking.mode` is defined as none or minimal, the following code block throws an error

      The `snapshotLockImplementations` list has a `NoLockingSupport` object , but the filter by name is done with "none"

      ```
      if (snapshotLock.isEmpty()) { // Fallback on generic implementation
      snapshotLock = snapshotLockImplementations.stream()
      .filter(byNameFilter)
      .findAny();
      snapshotLock.ifPresent(lockImpl -> LOGGER.warn("Found a not connector specific implementation {} for lock mode {}",
      lockImpl.getClass().getName(),
      snapshotLockMode));
      }

      return snapshotLock.map(snapshotLockImpl -> {
      snapshotLockImpl.configure(configuration.asMap());
      if (snapshotLockImpl instanceof BeanRegistryAware)

      { ((BeanRegistryAware) snapshotLockImpl).injectBeanRegistry(beanRegistry); }

      return snapshotLockImpl;
      })
      .orElseThrow(() -> new DebeziumException(String.format("Unable to find %s snapshot lock mode. Please check your configuration.", snapshotLockMode)));

      }
       
      ```

            rh-ee-mvitale Mario Fiore Vitale
            subkanthi Kanthi Subramanian
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

              Created:
              Updated:
              Resolved: