Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9446

Integration test library should provide utilities to assert connector state

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      The integration testing library for Connect could be expanded to include methods for verifying the state of connectors. Some possibilities are:

       

      public boolean connectorIsRunning(String connector);

      public boolean connectorIsFailed(String connector);

      public boolean connectorIsRunningWithTasks(String connector, int numTasks);

      public boolean connectorIsFailedWithTasksRunning(String connector, int numTasks);

      public boolean connectorAndTasksAreFailed(String connector, int numTasks);

       

      These could be used in conjunction with the various waitForCondition methods to easily wait for connectors to be started, failed, etc. during tests.

       

      Functionality like this is already present in some integration tests, but is implemented on a per-test basis instead of as part of the integration testing library itself.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              ChrisEgerton Chris Egerton
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: