[KAFKA-2250] ConcurrentModificationException in metrics reporting

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Unassigned
• Reporter: Jason Rosenberg
• Created: 04/Jun/15 19:53
• Updated: 15/Jun/15 06:12
• Resolved: 15/Jun/15 06:12

Description

This occurred in a broker log (we're running 0.8.2.1):

java.util.ConcurrentModificationException
        at java.util.HashMap$HashIterator.nextNode(HashMap.java:1429)
        at java.util.HashMap$KeyIterator.next(HashMap.java:1453)
        at java.util.Collections$UnmodifiableCollection$1.next(Collections.java:1042)
        at kafka.network.AbstractServerThread.countInterestOps(SocketServer.scala:188)
        at kafka.network.SocketServer$$anon$1$$anonfun$value$1.apply(SocketServer.scala:79)
        at kafka.network.SocketServer$$anon$1$$anonfun$value$1.apply(SocketServer.scala:79)
        at scala.collection.IndexedSeqOptimized$class.foldl(IndexedSeqOptimized.scala:57)
        at scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:66)
        at scala.collection.mutable.ArrayOps$ofRef.foldLeft(ArrayOps.scala:186)
        at kafka.network.SocketServer$$anon$1.value(SocketServer.scala:79)
        at kafka.network.SocketServer$$anon$1.value(SocketServer.scala:78)