You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2018/06/18 22:39:36 UTC
[kafka] branch 2.0 updated: KAFKA-7067;
Include new connector configs in system test assertion (#5242)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.0 by this push:
new 2e14d8f KAFKA-7067; Include new connector configs in system test assertion (#5242)
2e14d8f is described below
commit 2e14d8f7d08102087d25abd24162559e99b504c0
Author: Magesh Nandakumar <ma...@gmail.com>
AuthorDate: Mon Jun 18 15:37:26 2018 -0700
KAFKA-7067; Include new connector configs in system test assertion (#5242)
The new connector configs added in KIP-297 and KIP-298 need to be updated in the connect_rest_test.py so that the expected results match the actual.
---
tests/kafkatest/tests/connect/connect_rest_test.py | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/tests/kafkatest/tests/connect/connect_rest_test.py b/tests/kafkatest/tests/connect/connect_rest_test.py
index 3c7cd89..8b6157b 100644
--- a/tests/kafkatest/tests/connect/connect_rest_test.py
+++ b/tests/kafkatest/tests/connect/connect_rest_test.py
@@ -31,8 +31,13 @@ class ConnectRestApiTest(KafkaTest):
FILE_SOURCE_CONNECTOR = 'org.apache.kafka.connect.file.FileStreamSourceConnector'
FILE_SINK_CONNECTOR = 'org.apache.kafka.connect.file.FileStreamSinkConnector'
- FILE_SOURCE_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'header.converter', 'batch.size', 'topic', 'file', 'transforms'}
- FILE_SINK_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'header.converter', 'topics', 'file', 'transforms', 'topics.regex'}
+ FILE_SOURCE_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'header.converter', 'batch.size',
+ 'topic', 'file', 'transforms', 'config.action.reload', 'errors.retry.timeout', 'errors.retry.delay.max.ms',
+ 'errors.tolerance', 'errors.log.enable', 'errors.log.include.messages'}
+ FILE_SINK_CONFIGS = {'name', 'connector.class', 'tasks.max', 'key.converter', 'value.converter', 'header.converter', 'topics',
+ 'file', 'transforms', 'topics.regex', 'config.action.reload', 'errors.retry.timeout', 'errors.retry.delay.max.ms',
+ 'errors.tolerance', 'errors.log.enable', 'errors.log.include.messages', 'errors.deadletterqueue.topic.name',
+ 'errors.deadletterqueue.topic.replication.factor', 'errors.deadletterqueue.context.headers.enable'}
INPUT_FILE = "/mnt/connect.input"
INPUT_FILE2 = "/mnt/connect.input2"