You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2017/11/30 21:51:31 UTC

kafka git commit: KAFKA-6284: Fixed system test for Connect REST API

Repository: kafka
Updated Branches:
  refs/heads/trunk bc2c17a9b -> 18e34482e


KAFKA-6284: Fixed system test for Connect REST API

`topics.regex` was added in KAFKA-3073. This change fixes the test that invokes `/validate` to ensure that all the configdefs are returned as expected.

Author: Mikkin <mi...@confluent.io>

Reviewers: Randall Hauch <rh...@gmail.com>, Jason Gustafson <ja...@confluent.io>, Ewen Cheslack-Postava <ew...@confluent.io>

Closes #4279 from mikkin/KAFKA-6284


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/18e34482
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/18e34482
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/18e34482

Branch: refs/heads/trunk
Commit: 18e34482e685098ebef90233d78ae803f906633a
Parents: bc2c17a
Author: Mikkin <mi...@confluent.io>
Authored: Thu Nov 30 13:51:19 2017 -0800
Committer: Ewen Cheslack-Postava <me...@ewencp.org>
Committed: Thu Nov 30 13:51:19 2017 -0800

----------------------------------------------------------------------
 tests/kafkatest/tests/connect/connect_rest_test.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/18e34482/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 e1a2bf4..8172df3 100644
--- a/tests/kafkatest/tests/connect/connect_rest_test.py
+++ b/tests/kafkatest/tests/connect/connect_rest_test.py
@@ -32,7 +32,7 @@ class ConnectRestApiTest(KafkaTest):
     FILE_SINK_CONNECTOR = 'org.apache.kafka.connect.file.FileStreamSinkConnector'
 
     FILE_SOURCE_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'topic', 'file', 'transforms'}
-    FILE_SINK_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'topics', 'file', 'transforms'}
+    FILE_SINK_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'topics', 'file', 'transforms', 'topics.regex'}
 
     INPUT_FILE = "/mnt/connect.input"
     INPUT_FILE2 = "/mnt/connect.input2"