Since you're running Storm to read data from Kafka, I'd expect it is not due to 6349.
Could you provide a more detailed stack trace? The current provided one is really small and not informative at all. Guozhang On Tue, Dec 12, 2017 at 6:42 PM, Ted Yu <yuzhih...@gmail.com> wrote: > From the stack trace, it seems you hit KAFKA-6349 (where Damian provided a > PR). > > FYI > > On Mon, Dec 11, 2017 at 11:29 PM, Mr.Wang <1282183...@qq.com> wrote: > > > Hi~ > > We found this error when we read kafka data using storm: > > java.util.ConcurrentModificationException at > > java.util.LinkedHashMap$LinkedHashIterator.nextNode( > LinkedHashMap.java:719) > > at java.util.LinkedHashMap$LinkedKeyIterator.next( > LinkedHashMap.java:742) > > at java.util.AbstractCollection.addAll(AbstractCollection. > java:343)May > > I ask this to fix the program by ourselves? What code do we need to > > modify?Thanks! > -- -- Guozhang