Repository: kafka Updated Branches: refs/heads/trunk a553764c8 -> afaaea809
KAFKA-5954; Correct Connect REST API system test Author: Randall Hauch <rha...@gmail.com> Reviewers: tedyu <yuzhih...@gmail.com>, Ismael Juma <ism...@juma.me.uk> Closes #3934 from rhauch/kafka-5954 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/afaaea80 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/afaaea80 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/afaaea80 Branch: refs/heads/trunk Commit: afaaea8093d9d4f159cfd68d1f24ee36af3db8a0 Parents: a553764 Author: Randall Hauch <rha...@gmail.com> Authored: Thu Sep 21 16:45:35 2017 +0100 Committer: Ismael Juma <ism...@juma.me.uk> Committed: Thu Sep 21 16:46:10 2017 +0100 ---------------------------------------------------------------------- tests/kafkatest/tests/connect/connect_rest_test.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/afaaea80/tests/kafkatest/tests/connect/connect_rest_test.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/tests/connect/connect_rest_test.py b/tests/kafkatest/tests/connect/connect_rest_test.py index 105f196..e1a2bf4 100644 --- a/tests/kafkatest/tests/connect/connect_rest_test.py +++ b/tests/kafkatest/tests/connect/connect_rest_test.py @@ -115,7 +115,8 @@ class ConnectRestApiTest(KafkaTest): expected_source_info = { 'name': 'local-file-source', 'config': self._config_dict_from_props(source_connector_props), - 'tasks': [{'connector': 'local-file-source', 'task': 0}] + 'tasks': [{'connector': 'local-file-source', 'task': 0}], + 'type': 'source' } source_info = self.cc.get_connector("local-file-source") assert expected_source_info == source_info, "Incorrect info:" + json.dumps(source_info) @@ -124,7 +125,8 @@ class ConnectRestApiTest(KafkaTest): expected_sink_info = { 'name': 'local-file-sink', 'config': self._config_dict_from_props(sink_connector_props), - 'tasks': [{'connector': 'local-file-sink', 'task': 0}] + 'tasks': [{'connector': 'local-file-sink', 'task': 0}], + 'type': 'sink' } sink_info = self.cc.get_connector("local-file-sink") assert expected_sink_info == sink_info, "Incorrect info:" + json.dumps(sink_info)
