Description
KAFKA-5657 recently changed the REST response for several endpoints to include the connector type. The ConnectRestApiTest system test checks the response and compares to an expected document, and this is now failing:
[INFO:2017-09-21 12:53:42,875]: Triggering test 291 of 311...
[INFO:2017-09-21 12:53:42,883]: RunnerClient: Loading test {'directory': '/home/jenkins/workspace/system-test-kafka-trunk/kafka/tests/kafkatest/tests/connect', 'file_name': 'connect_rest_test.py', 'method_name': 'test_rest_api', 'cls_name': 'ConnectRestApiTest', 'injected_args': None}
[INFO:2017-09-21 12:53:44,051]: RunnerClient: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: Setting up...
[INFO:2017-09-21 12:53:53,274]: RunnerClient: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: Running...
[INFO:2017-09-21 12:54:27,193]: RunnerClient: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: FAIL: Incorrect info:{"type": "source", "tasks": [{"connector": "local-file-source", "task": 0}], "config": {"topic": "test", "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector", "name": "local-file-source", "file": "/mnt/connect.input", "tasks.max": "1"}, "name": "local-file-source"}
Traceback (most recent call last):
File "/home/jenkins/workspace/system-test-kafka-trunk/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.7.1-py2.7.egg/ducktape/tests/runner_client.py", line 132, in run
data = self.run_test()
File "/home/jenkins/workspace/system-test-kafka-trunk/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.7.1-py2.7.egg/ducktape/tests/runner_client.py", line 185, in run_test
return self.test_context.function(self.test)
File "/home/jenkins/workspace/system-test-kafka-trunk/kafka/tests/kafkatest/tests/connect/connect_rest_test.py", line 121, in test_rest_api
assert expected_source_info == source_info, "Incorrect info:" + json.dumps(source_info)
AssertionError: Incorrect info:{"type": "source", "tasks": [{"connector": "local-file-source", "task": 0}], "config": {"topic": "test", "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector", "name": "local-file-source", "file": "/mnt/connect.input", "tasks.max": "1"}, "name": "local-file-source"}
[INFO:2017-09-21 12:54:27,194]: RunnerClient: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: Tearing down...
[INFO:2017-09-21 12:54:34,249]: RunnerClient: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: Summary: Incorrect info:{"type": "source", "tasks": [{"connector": "local-file-source", "task": 0}], "config": {"topic": "test", "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector", "name": "local-file-source", "file": "/mnt/connect.input", "tasks.max": "1"}, "name": "local-file-source"}
Traceback (most recent call last):
File "/home/jenkins/workspace/system-test-kafka-trunk/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.7.1-py2.7.egg/ducktape/tests/runner_client.py", line 132, in run
data = self.run_test()
File "/home/jenkins/workspace/system-test-kafka-trunk/kafka/venv/local/lib/python2.7/site-packages/ducktape-0.7.1-py2.7.egg/ducktape/tests/runner_client.py", line 185, in run_test
return self.test_context.function(self.test)
File "/home/jenkins/workspace/system-test-kafka-trunk/kafka/tests/kafkatest/tests/connect/connect_rest_test.py", line 121, in test_rest_api
assert expected_source_info == source_info, "Incorrect info:" + json.dumps(source_info)
AssertionError: Incorrect info:{"type": "source", "tasks": [{"connector": "local-file-source", "task": 0}], "config": {"topic": "test", "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector", "name": "local-file-source", "file": "/mnt/connect.input", "tasks.max": "1"}, "name": "local-file-source"}
[INFO:2017-09-21 12:54:34,250]: RunnerClient: kafkatest.tests.connect.connect_rest_test.ConnectRestApiTest.test_rest_api: Data: None
[INFO:2017-09-21 12:54:34,366]: ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Attachments
Issue Links
- is broken by
-
KAFKA-5657 Connect REST API should include the connector type when describing a connector
-
- Resolved
-
- links to
