Copilot commented on code in PR #19999:
URL: https://github.com/apache/kafka/pull/19999#discussion_r2156902776
##########
tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py:
##########
@@ -129,10 +129,12 @@ def test_streams_runs_with_broker_down_initially(self,
metadata_quorum, group_pr
with processor_2.node.account.monitor_log(processor_2.STDOUT_FILE)
as monitor_2:
with
processor_3.node.account.monitor_log(processor_3.STDOUT_FILE) as monitor_3:
+ # repeating_keys enables production of records with keys,
ensuring that we produce to all 3 partitions
self.assert_produce(self.inputTopic,
"sending_message_after_broker_down_initially",
num_messages=self.num_messages,
- timeout_sec=120)
+ timeout_sec=120,
+ repeating_keys=self.num_messages)
Review Comment:
[nitpick] This comment is repeated verbatim across multiple test cases.
Consider abstracting the key-production logic into a helper or adding a shared
comment to reduce duplication.
--
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
