[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187299#comment-16187299 ]
Yogesh BG commented on KAFKA-5998: ---------------------------------- 17:48:31.389 [ks_0_inst-StreamThread-5] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.389 [ks_0_inst-StreamThread-6] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.391 [ks_0_inst-StreamThread-8] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.391 [ks_0_inst-StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.392 [ks_0_inst-StreamThread-15] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.392 [ks_0_inst-StreamThread-8] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.392 [ks_0_inst-StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.393 [ks_0_inst-StreamThread-15] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.484 [ks_0_inst-StreamThread-16] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.485 [ks_0_inst-StreamThread-16] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.485 [ks_0_inst-StreamThread-11] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.485 [ks_0_inst-StreamThread-2] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.485 [ks_0_inst-StreamThread-10] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.486 [ks_0_inst-StreamThread-2] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.486 [ks_0_inst-StreamThread-11] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.486 [ks_0_inst-StreamThread-10] INFO o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) dead for group rtp-kafkastreams 17:48:31.489 [ks_0_inst-StreamThread-7] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.489 [ks_0_inst-StreamThread-3] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.585 [ks_0_inst-StreamThread-16] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.586 [ks_0_inst-StreamThread-2] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.586 [ks_0_inst-StreamThread-11] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.587 [ks_0_inst-StreamThread-10] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.591 [ks_0_inst-StreamThread-7] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.591 [ks_0_inst-StreamThread-6] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.591 [ks_0_inst-StreamThread-3] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.592 [ks_0_inst-StreamThread-5] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.594 [ks_0_inst-StreamThread-15] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.595 [ks_0_inst-StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:31.595 [ks_0_inst-StreamThread-8] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 172.30.0.9:9092 (id: 2147482646 rack: null) for group rtp-kafkastreams. 17:48:32.018 [pool-5-thread-15] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 483 17:48:32.030 [pool-5-thread-8] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 672 17:48:32.030 [pool-5-thread-6] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 276 17:48:32.031 [pool-5-thread-13] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 458 17:48:32.031 [pool-5-thread-5] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 452 17:48:32.033 [pool-5-thread-11] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 447 17:48:32.039 [pool-5-thread-7] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 413 17:48:32.039 [pool-5-thread-7] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 413 17:48:32.042 [pool-5-thread-14] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 488 17:48:32.045 [pool-5-thread-4] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 579 17:48:32.060 [pool-5-thread-10] INFO n.a.elasticsearch.util.ESMetricStore - executeBatch : size = 573 17:48:32.102 [ks_0_inst-StreamThread-3] WARN o.a.k.s.p.i.ProcessorStateManager - Failed to write checkpoint file to /data/kstreams/rtp-kafkastreams/0_11/.checkpoint: java.io.FileNotFoundException: /data/kstreams/rtp-kafkastreams/0_11/.checkpoint.tmp (No such file or directory) at java.io.FileOutputStream.open(Native Method) ~[na:1.7.0_111] at java.io.FileOutputStream.<init>(FileOutputStream.java:221) ~[na:1.7.0_111] at java.io.FileOutputStream.<init>(FileOutputStream.java:171) ~[na:1.7.0_111] at org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(OffsetCheckpoint.java:73) ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(ProcessorStateManager.java:324) ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask$1.run(StreamTask.java:267) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:201) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:260) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:254) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.AssignedTasks$1.apply(AssignedTasks.java:322) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:415) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.AssignedTasks.commit(AssignedTasks.java:314) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.commitAll(StreamThread.java:700) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:683) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:523) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:480) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:457) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] 17:48:32.107 [ks_0_inst-StreamThread-16] WARN o.a.k.s.p.i.ProcessorStateManager - Failed to write checkpoint file to /data/kstreams/rtp-kafkastreams/0_15/.checkpoint: java.io.FileNotFoundException: /data/kstreams/rtp-kafkastreams/0_15/.checkpoint.tmp (No such file or directory) at java.io.FileOutputStream.open(Native Method) ~[na:1.7.0_111] at java.io.FileOutputStream.<init>(FileOutputStream.java:221) ~[na:1.7.0_111] at java.io.FileOutputStream.<init>(FileOutputStream.java:171) ~[na:1.7.0_111] at org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(OffsetCheckpoint.java:73) ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(ProcessorStateManager.java:324) ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask$1.run(StreamTask.java:267) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:201) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:260) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:254) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.AssignedTasks$1.apply(AssignedTasks.java:322) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:415) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.AssignedTasks.commit(AssignedTasks.java:314) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.commitAll(StreamThread.java:700) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:683) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:523) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:480) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:457) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] 17:48:32.111 [ks_0_inst-StreamThread-11] WARN o.a.k.s.p.i.ProcessorStateManager - Failed to write checkpoint file to /data/kstreams/rtp-kafkastreams/0_9/.checkpoint: java.io.FileNotFoundException: /data/kstreams/rtp-kafkastreams/0_9/.checkpoint.tmp (No such file or directory) at java.io.FileOutputStream.open(Native Method) ~[na:1.7.0_111] at java.io.FileOutputStream.<init>(FileOutputStream.java:221) ~[na:1.7.0_111] at java.io.FileOutputStream.<init>(FileOutputStream.java:171) ~[na:1.7.0_111] at org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(OffsetCheckpoint.java:73) ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(ProcessorStateManager.java:324) ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask$1.run(StreamTask.java:267) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:201) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:260) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:254) [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > /.checkpoint.tmp Not found exception > ------------------------------------ > > Key: KAFKA-5998 > URL: https://issues.apache.org/jira/browse/KAFKA-5998 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.11.0.0 > Reporter: Yogesh BG > Attachments: 5998.v1.txt > > > I have one kafka broker and one kafka stream running... I am running its > since two days under load of around 2500 msgs per second.. On third day am > getting below exception for some of the partitions, I have 16 partitions only > 0_0 and 0_1 gives this error > {{09:43:25.955 [ks_0_inst-StreamThread-6] WARN > o.a.k.s.p.i.ProcessorStateManager - Failed to write checkpoint file to > /data/kstreams/rtp-kafkastreams/0_1/.checkpoint: > java.io.FileNotFoundException: > /data/kstreams/rtp-kafkastreams/0_1/.checkpoint.tmp (No such file or > directory) > at java.io.FileOutputStream.open(Native Method) ~[na:1.7.0_111] > at java.io.FileOutputStream.<init>(FileOutputStream.java:221) > ~[na:1.7.0_111] > at java.io.FileOutputStream.<init>(FileOutputStream.java:171) > ~[na:1.7.0_111] > at > org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(OffsetCheckpoint.java:73) > ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(ProcessorStateManager.java:324) > ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamTask$1.run(StreamTask.java:267) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:201) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:260) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:254) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.AssignedTasks$1.apply(AssignedTasks.java:322) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:415) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.AssignedTasks.commit(AssignedTasks.java:314) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.commitAll(StreamThread.java:700) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:683) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:523) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:480) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:457) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > 09:43:25.974 [ks_0_inst-StreamThread-15] WARN > o.a.k.s.p.i.ProcessorStateManager - Failed to write checkpoint file to > /data/kstreams/rtp-kafkastreams/0_0/.checkpoint: > java.io.FileNotFoundException: > /data/kstreams/rtp-kafkastreams/0_0/.checkpoint.tmp (No such file or > directory) > at java.io.FileOutputStream.open(Native Method) ~[na:1.7.0_111] > at java.io.FileOutputStream.<init>(FileOutputStream.java:221) > ~[na:1.7.0_111] > at java.io.FileOutputStream.<init>(FileOutputStream.java:171) > ~[na:1.7.0_111] > at > org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(OffsetCheckpoint.java:73) > ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(ProcessorStateManager.java:324) > ~[rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamTask$1.run(StreamTask.java:267) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:201) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:260) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:254) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.AssignedTasks$1.apply(AssignedTasks.java:322) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:415) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.AssignedTasks.commit(AssignedTasks.java:314) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.commitAll(StreamThread.java:700) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:683) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:523) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:480) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:457) > [rtp-kafkastreams-1.0-SNAPSHOT-jar-with-dependencies.jar:na] > }} -- This message was sent by Atlassian JIRA (v6.4.14#64029)