01:26:32.470 [publish-driver] ERROR io.druid.indexing.kafka.KafkaIndexTask - Error in publish thread, dying: {class=io.druid.indexing.kafka.KafkaIndexTask, exceptionType=class java.util.ConcurrentModificationException, exceptionMessage=null}
java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextNode(HashMap.java:1429) ~[?:1.8.0_91]
at java.util.HashMap$KeyIterator.next(HashMap.java:1453) ~[?:1.8.0_91]
at java.util.AbstractCollection.toString(AbstractCollection.java:461) ~[?:1.8.0_91]
at java.lang.String.valueOf(String.java:2994) ~[?:1.8.0_91]
at java.lang.StringBuilder.append(StringBuilder.java:131) ~[?:1.8.0_91]
at io.druid.indexing.kafka.KafkaIndexTask$SequenceMetadata.toString(KafkaIndexTask.java:2175) ~[?:?]
at java.lang.String.valueOf(String.java:2994) ~[?:1.8.0_91]
at java.util.Arrays.toString(Arrays.java:4571) ~[?:1.8.0_91]
at java.util.concurrent.CopyOnWriteArrayList.toString(CopyOnWriteArrayList.java:1011) ~[?:1.8.0_91]
at java.util.Formatter$FormatSpecifier.printString(Formatter.java:2886) ~[?:1.8.0_91]
at java.util.Formatter$FormatSpecifier.print(Formatter.java:2763) ~[?:1.8.0_91]
at java.util.Formatter.format(Formatter.java:2520) ~[?:1.8.0_91]
at java.util.Formatter.format(Formatter.java:2455) ~[?:1.8.0_91]
at java.lang.String.format(String.java:2981) ~[?:1.8.0_91]
at io.druid.java.util.common.StringUtils.nonStrictFormat(StringUtils.java:122) ~[java-util-0.12.0.jar:0.12.0]
at io.druid.java.util.common.logger.Logger.info(Logger.java:78) ~[java-util-0.12.0.jar:0.12.0]
at io.druid.indexing.kafka.KafkaIndexTask.persistSequences(KafkaIndexTask.java:1315) ~[?:?]
at io.druid.indexing.kafka.KafkaIndexTask.lambda$createAndStartPublishExecutor$1(KafkaIndexTask.java:388) ~[?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_91]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_91]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_91]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_91]
