jayteej commented on code in PR #18140:
URL: https://github.com/apache/kafka/pull/18140#discussion_r1884176073
##########
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala:
##########
@@ -625,7 +626,7 @@ class DynamicBrokerReconfigurationTest extends
QuorumTestHarness with SaslSetup
"Config not updated in LogManager")
val log = servers.head.logManager.getLog(new TopicPartition(topic,
0)).getOrElse(throw new IllegalStateException("Log not found"))
- TestUtils.waitUntilTrue(() => log.config.segmentSize == 4000, "Existing
topic config using defaults not updated")
+ TestUtils.waitUntilTrue(() => log.config.segmentSize == 1048576, "Existing
topic config using defaults not updated")
Review Comment:
I will have to improve the produce/consume part of this test to fill a 1MB
segment. I will have a go at this. There is complexity because it is racey and
the default producer is sending to 10 partitions.
--
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
