[
https://issues.apache.org/jira/browse/KAFKA-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878290#comment-17878290
]
Chia-Ping Tsai commented on KAFKA-17454:
----------------------------------------
[~jolshan] thanks for response {*}{*}{*}{*}
*why
[https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e]
does not fix it?*
The fix of
[https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e]
is to NOT collect the log from path
`/mnt/kafka/kafka-operational-logs/debug/xxxx.log`if the task is successful. It
does not change the log level. see ducktape
[https://github.com/confluentinc/ducktape/blob/b2ad7693f2750a2286a5099882ecc774fd7138b2/ducktape/tests/test.py#L181]
*why
[https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e]
does not see the error of "sort"*
[https://github.com/apache/kafka/commit/df04887ba597941674a28d54bd35202bbd21631e]
does NOT show the error since the number of features is only "one" (only
metadata.version). Hence, the bug is not triggered as it does not need to
"sort". Now, we have two features - metadata.version and krafe.version - so the
sort is executed and then we see the "hello bug"
*why we should change the kafka.log_level to INFO?*
the template of log4j.properties is controlled by `log_level`
([https://github.com/apache/kafka/blob/trunk/tests/kafkatest/services/kafka/templates/log4j.properties#L16),]
and the bug happens in writing debug message
([https://github.com/apache/kafka/blob/e4ca066680296ea29d443efb626baecc837083f6/core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala#L274)|https://github.com/apache/kafka/blob/e4ca066680296ea29d443efb626baecc837083f6/core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala#L274).].
Hence, changing the log level to DEBUG can avoid triggering the bug.
> Fix failed transactions_mixed_versions_test.py when running with 3.2
> --------------------------------------------------------------------
>
> Key: KAFKA-17454
> URL: https://issues.apache.org/jira/browse/KAFKA-17454
> Project: Kafka
> Issue Type: Test
> Reporter: Chia-Ping Tsai
> Assignee: Chia-Ping Tsai
> Priority: Blocker
> Fix For: 4.0.0, 3.9.0
>
>
> 3.2.3 release does not include KAFKA-14259, so it will produce exception
> (shown below) when log level is DEBUG. Hence, we should change the log level
> from DEBUG to INFO for 3.2.3
> for example: add `self.kafka.log_level = "INFO"`
> {code:java}
> Caused by: java.lang.ClassCastException: java.util.HashMap$Node cannot be
> cast to java.lang.Comparable
> at
> java.util.Comparators$NaturalOrderComparator.compare(Comparators.java:47)
> at java.util.TimSort.countRunAndMakeAscending(TimSort.java:355)
> at java.util.TimSort.sort(TimSort.java:220)
> at java.util.Arrays.sort(Arrays.java:1512)
> at
> java.util.stream.SortedOps$SizedRefSortingSink.end(SortedOps.java:353)
> at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:483)
> at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
> at
> java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
> at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> at
> java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
> at
> org.apache.kafka.metadata.BrokerRegistration.toString(BrokerRegistration.java:212)
> at java.util.Formatter$FormatSpecifier.printString(Formatter.java:2886)
> at java.util.Formatter$FormatSpecifier.print(Formatter.java:2763)
> at java.util.Formatter.format(Formatter.java:2520)
> at java.util.Formatter.format(Formatter.java:2455)
> at java.lang.String.format(String.java:2940)
> at java.util.Optional.toString(Optional.java:346)
> at java.lang.String.valueOf(String.java:2994)
> at java.lang.StringBuilder.append(StringBuilder.java:136)
> at java.util.AbstractMap.toString(AbstractMap.java:559)
> at java.lang.String.valueOf(String.java:2994)
> at java.lang.StringBuilder.append(StringBuilder.java:136)
> at org.apache.kafka.image.ClusterDelta.toString(ClusterDelta.java:132)
> at java.lang.String.valueOf(String.java:2994)
> at java.lang.StringBuilder.append(StringBuilder.java:136)
> at org.apache.kafka.image.MetadataDelta.toString(MetadataDelta.java:353)
> at java.lang.String.valueOf(String.java:2994)
> at java.lang.StringBuilder.append(StringBuilder.java:136)
> at
> kafka.server.metadata.BrokerMetadataListener.$anonfun$publish$1(BrokerMetadataListener.scala:274)
> at kafka.utils.Logging.debug(Logging.scala:62)
> at kafka.utils.Logging.debug$(Logging.scala:62)
> at
> kafka.server.metadata.BrokerMetadataListener.debug(BrokerMetadataListener.scala:37)
> at
> kafka.server.metadata.BrokerMetadataListener.kafka$server$metadata$BrokerMetadataListener$$publish(BrokerMetadataListener.scala:274)
> at
> kafka.server.metadata.BrokerMetadataListener$StartPublishingEvent.run(BrokerMetadataListener.scala:241)
> at
> org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:121)
> at
> org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:200)
> at
> org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:173)
> at java.lang.Thread.run(Thread.java:750)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
