Chris Egerton created KAFKA-9446: ------------------------------------ Summary: Integration test library should provide utilities to assert connector state Key: KAFKA-9446 URL: https://issues.apache.org/jira/browse/KAFKA-9446 Project: Kafka Issue Type: Improvement Components: KafkaConnect Reporter: Chris Egerton
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|https://github.com/apache/kafka/blob/6d87c12729ac6dc9d39949c931fad4c45c6af841/clients/src/test/java/org/apache/kafka/test/TestUtils.java#L335-L372] 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)