[jira] [Updated] (KAFKA-14193) Connect system test ConnectRestApiTest is failing

["Jose Armando Garcia Sancio (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jose Armando Garcia Sancio updated KAFKA-14193:
-----------------------------------------------
    Affects Version/s: 3.3.0

> Connect system test ConnectRestApiTest is failing
> -------------------------------------------------
>
>                 Key: KAFKA-14193
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14193
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>    Affects Versions: 3.3.0
>            Reporter: Yash Mayya
>            Assignee: Yash Mayya
>            Priority: Major
>             Fix For: 3.3.0
>
>
> [ConnectRestApiTest|https://github.com/apache/kafka/blob/trunk/tests/kafkatest/tests/connect/connect_rest_test.py] is currently failing on `trunk` and `3.3` with the following assertion error:
>  
>  
> {code:java}
> AssertionError()
> Traceback (most recent call last):
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", line 183, in _do_run
>     data = self.run_test()
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", line 243, in run_test
>     return self.test_context.function(self.test)
>   File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 433, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_rest_test.py", line 106, in test_rest_api
>     self.verify_config(self.FILE_SOURCE_CONNECTOR, self.FILE_SOURCE_CONFIGS, configs)
>   File "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_rest_test.py", line 219, in verify_config
>     assert config_def == set(config_names){code}
> On closer inspection, this is because of the new source connector EOS related configs added in [https://github.com/apache/kafka/pull/11775.] Adding the following new configs - 
> {code:java}
> offsets.storage.topic, transaction.boundary, exactly.once.support, transaction.boundary.interval.ms{code}
> in the expected config defs [here|https://github.com/apache/kafka/blob/6f4778301b1fcac1e2750cc697043d674eaa230d/tests/kafkatest/tests/connect/connect_rest_test.py#L35] fixes the tests on the 3.3 branch. However, the tests still fail on trunk due to the changes from [https://github.com/apache/kafka/pull/12450.]
>  
> The plan to fix this is to raise two PRs against trunk patching connect_rest_test.py - the first one fixing the EOS configs related issue which can be backported to 3.3 and the second one fixing the issue related to propagation of full connector configs to tasks which shouldn't be backported to 3.3 (because the commit from https://github.com/apache/kafka/pull/12450 is only on trunk and not on 3.3)
>  
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)