root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-9078: Fix Connect system test after adding MM2 connector classes 

MM2 added a few connector classes in Connect's classpath and given that the assertion in the Connect REST system tests need to be adjusted to account for these additions.

This fix makes sure that the loaded Connect plugins are a superset of the expected by the test connectors.

Testing: The change is straightforward. The fix was tested with local system test runs.

Author: Konstantine Karantasis <konstantine@confluent.io>

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>

Closes #7578 from kkonstantine/minor-fix-connect-test-after-mm2-classes
This commit is contained in:
Konstantine Karantasis 2019-10-23 15:46:26 +05:30 committed by Manikumar Reddy
parent 4fc649d85c
commit fc0963a236
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/kafkatest/tests/connect/connect_rest_test.py
View File

@ -91,7 +91,10 @@ class ConnectRestApiTest(KafkaTest):
assert self.cc.list_connectors() == []
assert set([connector_plugin['class'] for connector_plugin in self.cc.list_connector_plugins()]) == {self.FILE_SOURCE_CONNECTOR, self.FILE_SINK_CONNECTOR}
# After MM2 and the connector classes that it added, the assertion here checks that the registered
# Connect plugins are a superset of the connectors expected to be present.
assert set([connector_plugin['class'] for connector_plugin in self.cc.list_connector_plugins()]).issuperset(
{self.FILE_SOURCE_CONNECTOR, self.FILE_SINK_CONNECTOR})
source_connector_props = self.render("connect-file-source.properties")
sink_connector_props = self.render("connect-file-sink.properties")