This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 092dc7fc467 KAFKA-16238: Fix ConnectRestApiTest system test (#15346)
092dc7fc467 is described below
commit 092dc7fc467ed7d354ec504d6939b3fcd7b80632
Author: Mickael Maison <mimai...@users.noreply.github.com>
AuthorDate: Fri Feb 9 13:36:56 2024 +0100
KAFKA-16238: Fix ConnectRestApiTest system test (#15346)
Reviewers: Yash Mayya <yash.ma...@gmail.com>
---
tests/kafkatest/tests/connect/connect_rest_test.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/tests/kafkatest/tests/connect/connect_rest_test.py
b/tests/kafkatest/tests/connect/connect_rest_test.py
index e3d023c9dfb..da3e5be534b 100644
--- a/tests/kafkatest/tests/connect/connect_rest_test.py
+++ b/tests/kafkatest/tests/connect/connect_rest_test.py
@@ -36,11 +36,13 @@ class ConnectRestApiTest(KafkaTest):
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', 'predicates', 'topic.creation.groups',
- 'exactly.once.support', 'transaction.boundary',
'transaction.boundary.interval.ms', 'offsets.storage.topic'}
+ 'exactly.once.support', 'transaction.boundary',
'transaction.boundary.interval.ms', 'offsets.storage.topic',
+ 'tasks.max.enforce'}
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', 'predicates'}
+ 'errors.deadletterqueue.topic.replication.factor',
'errors.deadletterqueue.context.headers.enable', 'predicates',
+ 'tasks.max.enforce'}
INPUT_FILE = "/mnt/connect.input"
INPUT_FILE2 = "/mnt/connect.input2"
