yashmayya opened a new pull request, #12575: URL: https://github.com/apache/kafka/pull/12575
- [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: ``` 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) ``` - 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 - `offsets.storage.topic, transaction.boundary, exactly.once.support, transaction.boundary.interval.ms` 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 is the first of the two PRs and should be backported to `3.3` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
