kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yogesh BG (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception
Date Sun, 01 Oct 2017 06:54:00 GMT

    [ 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)

Mime
View raw message