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

Add STOPPED and RESTARTING connector states to testing library

    XMLWordPrintable

Details

    • Enhancement
    • Resolution: Done
    • Major
    • 2.4.0.Alpha2
    • None
    • testcontainers
    • None
    • False
    • None
    • False

    Description

      Which use case/requirement will be addressed by the proposed feature?

      Background: We use Debezium Docker images to perform integration testing for kcctl. Recently, we added support for stopping (but not deleting) connectors, which was introduced in Kafka Connect 3.5 as part of KIP-875.

      Use case: We'd like to use the DebeziumContainer::ensureConnectorState method as part of our tests, but the Connector.State enum doesn't contain the STOPPED state, so currently we have to implement this logic on our own.

      Additionally, the RESTARTING state that was added in KIP-745 can cause an IllegalStateException to be thrown from calls to DebeziumContainer::ensureConnectorState and DebeziumContainer::ensureConnectorTaskState if the state for a connector or task is RESTARTING, since that does not correspond to a valid value for the Connector.State enum.

      Implementation ideas (optional)

      Add the values STOPPED and RESTARTING to the  Connector.State enum.

      Attachments

        Activity

          People

            Unassigned Unassigned
            chrise@aiven Chris Egerton (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: