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

KAFKA-5954; Correct Connect REST API system test 

Author: Randall Hauch <rhauch@gmail.com>

Reviewers: tedyu <yuzhihong@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #3934 from rhauch/kafka-5954
This commit is contained in:
Randall Hauch 2017-09-21 16:45:35 +01:00 committed by Ismael Juma
parent a553764c8b
commit afaaea8093
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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)