cmccabe commented on code in PR #17601:
URL: https://github.com/apache/kafka/pull/17601#discussion_r1821609247
##########
tests/kafkatest/tests/connect/connect_distributed_test.py:
##########
@@ -998,54 +858,6 @@ def test_transformations(self, connect_protocol,
metadata_quorum, use_new_coordi
assert obj['payload']['content'] in self.FIRST_INPUT_LIST
assert obj['payload'][ts_fieldname] == ts
- @cluster(num_nodes=5)
- @parametrize(broker_version=str(DEV_BRANCH), auto_create_topics=False,
exactly_once_source=True, connect_protocol='sessioned')
Review Comment:
This is a weird mismash of ancient Kafka versions. But shouldn't we at least
keep the test cases where we're testing DEV_BRANCH (and possibly add some
non-ancient versions to test, perhaps even supported versions?)
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
