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

Add STOPPED and RESTARTING connector states to testing library

XMLWordPrintable

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

      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.

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

              Created:
              Updated:
              Resolved: