chia7712 commented on code in PR #16614:
URL: https://github.com/apache/kafka/pull/16614#discussion_r1681099940
##########
core/src/test/scala/unit/kafka/log/LogManagerTest.scala:
##########
@@ -957,6 +957,17 @@ class LogManagerTest {
val topicPartition = UnifiedLog.parseTopicPartitionName(dir)
val config = topicConfigOverrides.getOrElse(topicPartition.topic,
logConfig)
+ if (dir == logDir2) {
Review Comment:
Yep, this is the one of the solutions I described in the jira. It does not
change production code but it can't fix the issue totally.
If we don't want to touch production code, maybe another way is to change
the folders from 2 to 1. Not sure whether this is valid to this test case.
--
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
