[
https://issues.apache.org/jira/browse/KAFKA-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-17454:
-----------------------------------
Fix Version/s: 4.0.0
3.9.0
> 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: Major
> 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)
