[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16034356#comment-16034356 ] Lukas Gemela commented on KAFKA-5154: - [~guozhang] no worries, thank you for the fix, we will update

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011966#comment-16011966 ] Lukas Gemela edited comment on KAFKA-5154 at 5/16/17 8:37 AM: -- [~mjsax] I

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011982#comment-16011982 ] Lukas Gemela edited comment on KAFKA-5154 at 5/16/17 8:33 AM: -- [~guozhang]

[jira] [Updated] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5154: Attachment: clio_afa596e9b809.gz [~guozhang] full logs attached. > Kafka Streams throws NPE

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011966#comment-16011966 ] Lukas Gemela commented on KAFKA-5154: - [~mjsax] I really can't give you any ultimate answer for

[jira] [Comment Edited] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011222#comment-16011222 ] Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 7:48 PM: -- We used two

[jira] [Comment Edited] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010974#comment-16010974 ] Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 5:50 PM: -- [~mjsax] by

[jira] [Comment Edited] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010974#comment-16010974 ] Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 5:50 PM: -- [~mjsax] by

[jira] [Comment Edited] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010974#comment-16010974 ] Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 5:48 PM: -- [~mjsax] by

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Attachment: clio_170511.log > add max_number _of_retries to exponential backoff strategy >

[jira] [Commented] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010974#comment-16010974 ] Lukas Gemela commented on KAFKA-5242: - [~mjsax] by multiple instances you mean multiple JVMs (nodes)

[jira] [Updated] (KAFKA-5240) Make persistent checkpointedOffsets optionable

[ https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5240: Priority: Minor (was: Major) > Make persistent checkpointedOffsets optionable >

[jira] [Updated] (KAFKA-5240) Make persistent checkpointedOffsets optionable

[ https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5240: Description: By looking at the ProcessorStateManager class kafka streams library tries to persist

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Priority: Minor (was: Major) > add max_number _of_retries to exponential backoff strategy >

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Description: >From time to time, during relabance we are getting a lot of exceptions saying

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Attachment: (was: clio_170511.log) > add max_number _of_retries to exponential backoff strategy

[jira] [Updated] (KAFKA-5242) add max_number _of_retries to exponential backoff strategy

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Summary: add max_number _of_retries to exponential backoff strategy (was: state task directory

[jira] [Updated] (KAFKA-5242) state task directory locked forever

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Issue Type: Improvement (was: Bug) > state task directory locked forever >

[jira] [Updated] (KAFKA-5242) state task directory locked forever

[ https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5242: Description: >From time to time, during relabance we are getting a lot of exceptions saying

[jira] [Updated] (KAFKA-5240) Make persistent checkpointedOffsets optionable

[ https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5240: Description: By looking at the ProcessorStateManager class kafka streams library tries to persist

[jira] [Created] (KAFKA-5242) state task directory locked forever

Lukas Gemela created KAFKA-5242: --- Summary: state task directory locked forever Key: KAFKA-5242 URL: https://issues.apache.org/jira/browse/KAFKA-5242 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5240) Make persistent checkpointedOffsets optionable

Lukas Gemela created KAFKA-5240: --- Summary: Make persistent checkpointedOffsets optionable Key: KAFKA-5240 URL: https://issues.apache.org/jira/browse/KAFKA-5240 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010143#comment-16010143 ] Lukas Gemela commented on KAFKA-5154: - [~mjsax] logs attached (clio_reduced) It's just log from two

[jira] [Updated] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5154: Attachment: clio_reduced.gz > Kafka Streams throws NPE during rebalance >

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002457#comment-16002457 ] Lukas Gemela commented on KAFKA-5154: - today we reproduced the issue on two of our nodes, hope it

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001501#comment-16001501 ] Lukas Gemela commented on KAFKA-5154: - [~guozhang] Yes I know log does not contain NPE, I just wanted

[jira] [Updated] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Gemela updated KAFKA-5154: Attachment: clio.txt.gz > Kafka Streams throws NPE during rebalance >

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997141#comment-15997141 ] Lukas Gemela commented on KAFKA-5154: - I just found the exception from my previous comment in one of

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996995#comment-15996995 ] Lukas Gemela edited comment on KAFKA-5154 at 5/4/17 4:26 PM: - I wasnt able to

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996995#comment-15996995 ] Lukas Gemela commented on KAFKA-5154: - I wasnt able to reproduce the issue yet, but I just found in

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15994646#comment-15994646 ] Lukas Gemela commented on KAFKA-5154: - Ok I've made it running with kafka streams tag 0.10.2.0 plus

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15994475#comment-15994475 ] Lukas Gemela commented on KAFKA-5154: - [~mjsax] should not be a problem, I can make it running on one

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 11:10 PM: -- Hi, we have a

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:56 PM: -- Hi, we have a

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:35 PM: -- Hi, we have a

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:34 PM: -- Hi, we have a

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:33 PM: -- Hi, we have a

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:33 PM: -- Hi, we have a

[jira] [Comment Edited] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:27 PM: -- Hi, we have a

[jira] [Commented] (KAFKA-5154) Kafka Streams throws NPE during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993902#comment-15993902 ] Lukas Gemela commented on KAFKA-5154: - Hi, we have a kafka streams app consuming from one topic,

[jira] [Created] (KAFKA-5154) Kafka Streams throws NPE during rebalance

Lukas Gemela created KAFKA-5154: --- Summary: Kafka Streams throws NPE during rebalance Key: KAFKA-5154 URL: https://issues.apache.org/jira/browse/KAFKA-5154 Project: Kafka Issue Type: Bug