kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-5954; Correct Connect REST API system test
Date Thu, 21 Sep 2017 15:46:27 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk a553764c8 -> afaaea809


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


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 <rhauch@gmail.com>
Authored: Thu Sep 21 16:45:35 2017 +0100
Committer: Ismael Juma <ismael@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)


Mime
View raw message