[
https://issues.apache.org/jira/browse/KAFKA-14259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-14259.
------------------------------------------------
Resolution: Fixed
> BrokerRegistration#toString throws an exception, terminating metadata replay
> ----------------------------------------------------------------------------
>
> Key: KAFKA-14259
> URL: https://issues.apache.org/jira/browse/KAFKA-14259
> Project: Kafka
> Issue Type: Bug
> Reporter: Colin McCabe
> Assignee: Colin McCabe
> Priority: Blocker
> Fix For: 3.3.0
>
>
> BrokerRegistration#toString throws an exception, terminating metadata replay,
> because the sorted() method is used on an entry set rather than a key set.
> {noformat}
> Caused by:
>
>
> java.util.concurrent.ExecutionException:
> java.lang.ClassCastException: class java.util.HashMap$Node cannot be cast to
> class java.lang.Comparable (java.util.HashMap$Node and java.lan
> g.Comparable are in module java.base of loader 'bootstrap')
>
>
> at
> java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
>
>
> at
> java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
>
>
> at kafka.server.BrokerServer.startup(BrokerServer.scala:846)
>
>
> ... 147 more
>
>
>
>
>
> Caused by:
>
>
> java.lang.ClassCastException: class java.util.HashMap$Node cannot
> be cast to class java.lang.Comparable (java.util.HashMap$Node and
> java.lang.Comparable are in module java.base
> of loader 'bootstrap')
>
>
> at
> java.base/java.util.Comparators$NaturalOrderComparator.compare(Comparators.java:47)
>
>
> at
> java.base/java.util.TimSort.countRunAndMakeAscending(TimSort.java:355)
>
>
> at java.base/java.util.TimSort.sort(TimSort.java:220)
>
>
> at java.base/java.util.Arrays.sort(Arrays.java:1307)
>
>
> at
> java.base/java.util.stream.SortedOps$SizedRefSortingSink.end(SortedOps.java:353)
>
>
> at
> java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:510)
>
>
> at
> java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
>
>
> at
> java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
>
>
> at
> java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
>
>
> at
> java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
>
>
> at
> org.apache.kafka.metadata.BrokerRegistration.toString(BrokerRegistration.java:228)
>
>
> at
> java.base/java.util.Formatter$FormatSpecifier.printString(Formatter.java:3056)
>
>
> at
> java.base/java.util.Formatter$FormatSpecifier.print(Formatter.java:2933)
>
>
> at java.base/java.util.Formatter.format(Formatter.java:2689)
>
>
> at java.base/java.util.Formatter.format(Formatter.java:2625)
>
>
> at java.base/java.lang.String.format(String.java:4143)
> at java.base/java.util.Optional.toString(Optional.java:457)
> at java.base/java.lang.String.valueOf(String.java:4218)
> at
> java.base/java.lang.StringBuilder.append(StringBuilder.java:173)
> at
> java.base/java.util.AbstractMap.toString(AbstractMap.java:555)
> at java.base/java.lang.String.valueOf(String.java:4218)
> at
> java.base/java.lang.StringBuilder.append(StringBuilder.java:173)
> at
> org.apache.kafka.image.ClusterDelta.toString(ClusterDelta.java:225)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
