[jira] [Comment Edited] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270867#comment-16270867 ] Anil edited comment on KAFKA-6281 at 11/30/17 5:32 AM: --- Thanks [~omk

[jira] [Updated] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6024: -- Description: In several methods, parameter validation is done after calling acquireAndEnsureOpen() : {code}

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272142#comment-16272142 ] Nick Travers commented on KAFKA-4669: - [~hachikuji] - unfortunately, we only have the

[jira] [Comment Edited] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272013#comment-16272013 ] Matthias J. Sax edited comment on KAFKA-6269 at 11/30/17 1:56 AM: --

[jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272013#comment-16272013 ] Matthias J. Sax commented on KAFKA-6269: About the workaround. You could mask {{nu

[jira] [Comment Edited] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16272013#comment-16272013 ] Matthias J. Sax edited comment on KAFKA-6269 at 11/30/17 1:55 AM: --

[jira] [Created] (KAFKA-6286) Consider reusing materialized store for multi-same-stream join

Guozhang Wang created KAFKA-6286: Summary: Consider reusing materialized store for multi-same-stream join Key: KAFKA-6286 URL: https://issues.apache.org/jira/browse/KAFKA-6286 Project: Kafka

[jira] [Updated] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5936: --- Fix Version/s: (was: 1.0.1) 1.1.0 > KafkaProducer should not wrap Inter

[jira] [Commented] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271920#comment-16271920 ] ASF GitHub Bot commented on KAFKA-5936: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271906#comment-16271906 ] aarti gupta commented on KAFKA-4669: unfortunately we did not have trace enabled and d

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271902#comment-16271902 ] Jason Gustafson commented on KAFKA-4669: [~aartigupta] The consumer logs would pro

[jira] [Comment Edited] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271894#comment-16271894 ] aarti gupta edited comment on KAFKA-4669 at 11/30/17 12:32 AM: -

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271894#comment-16271894 ] aarti gupta commented on KAFKA-4669: [~hachikuji] I can send you the zookeeper and kaf

[jira] [Updated] (KAFKA-6284) System Test failed: ConnectRestApiTest

[ https://issues.apache.org/jira/browse/KAFKA-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikkin Patel updated KAFKA-6284: Fix Version/s: (was: 1.0.1) 1.1.0 > System Test failed: ConnectRestApiTest >

[jira] [Updated] (KAFKA-6284) System Test failed: ConnectRestApiTest

[ https://issues.apache.org/jira/browse/KAFKA-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikkin Patel updated KAFKA-6284: Affects Version/s: (was: 1.0.1) 1.1.0 > System Test failed: ConnectRestAp

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271832#comment-16271832 ] Jason Gustafson commented on KAFKA-4669: [~nickt] [~aartigupta] Do either of you h

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271827#comment-16271827 ] Jason Gustafson commented on KAFKA-4669: Reopened since there are two reported cas

[jira] [Reopened] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-4669: > KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws > exception > ---

[jira] [Updated] (KAFKA-5526) KIP-175: ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5526: --- Fix Version/s: 1.1.0 > KIP-175: ConsumerGroupCommand no longer shows output for consumer group

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271756#comment-16271756 ] Jason Gustafson commented on KAFKA-6260: I think this issue is probably not as sev

[jira] [Updated] (KAFKA-5638) Inconsistency in consumer group related ACLs

[ https://issues.apache.org/jira/browse/KAFKA-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5638: --- Fix Version/s: 1.1.0 > Inconsistency in consumer group related ACLs >

[jira] [Updated] (KAFKA-5638) Inconsistency in consumer group related ACLs

[ https://issues.apache.org/jira/browse/KAFKA-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5638: --- Affects Version/s: 1.0.0 > Inconsistency in consumer group related ACLs >

[jira] [Updated] (KAFKA-5638) Inconsistency in consumer group related ACLs

[ https://issues.apache.org/jira/browse/KAFKA-5638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5638: --- Labels: kip (was: needs-kip) > Inconsistency in consumer group related ACLs > ---

[jira] [Comment Edited] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271727#comment-16271727 ] aarti gupta edited comment on KAFKA-4669 at 11/29/17 11:01 PM: -

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271727#comment-16271727 ] aarti gupta commented on KAFKA-4669: We saw this in production today ERROR c.v.v.h.m.

[jira] [Commented] (KAFKA-6227) Kafka 0.11.01 New consumer - multiple consumers under same group not working as expected

[ https://issues.apache.org/jira/browse/KAFKA-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271488#comment-16271488 ] Ramkumar commented on KAFKA-6227: - I think I found the kafka behavior that may cause the

[jira] [Created] (KAFKA-6285) OffsetCommitRequest should have read-after-write logic

Dong Lin created KAFKA-6285: --- Summary: OffsetCommitRequest should have read-after-write logic Key: KAFKA-6285 URL: https://issues.apache.org/jira/browse/KAFKA-6285 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6284) System Test failed: ConnectRestApiTest

Mikkin Patel created KAFKA-6284: --- Summary: System Test failed: ConnectRestApiTest Key: KAFKA-6284 URL: https://issues.apache.org/jira/browse/KAFKA-6284 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271405#comment-16271405 ] Matthias J. Sax commented on KAFKA-5882: The JIRA is marked for {{0.11.0.0}}: ther

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271400#comment-16271400 ] Jason Gustafson commented on KAFKA-6260: [~habdank] If possible, can you test with

[jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271399#comment-16271399 ] Guozhang Wang commented on KAFKA-6269: -- [~andreas-schroeder] We have spotted the regr

[jira] [Commented] (KAFKA-6282) exactly_once semantics breaks demo application

[ https://issues.apache.org/jira/browse/KAFKA-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271398#comment-16271398 ] Matthias J. Sax commented on KAFKA-6282: Transactions by default require a replica

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271393#comment-16271393 ] Guozhang Wang commented on KAFKA-6260: -- Ack, thanks!! > AbstractCoordinator not clea

[jira] [Closed] (KAFKA-4827) Kafka connect: error with special characters in connector name

[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish closed KAFKA-4827. --- Changes have been merged and backported to 0.10.0, 0.10.1, 0.10.2 and 0.11.0 branches. > Kafka connect:

[jira] [Commented] (KAFKA-4827) Kafka connect: error with special characters in connector name

[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271391#comment-16271391 ] ASF GitHub Bot commented on KAFKA-4827: --- Github user wicknicks closed the pull reque

[jira] [Commented] (KAFKA-6259) Make KafkaStreams.cleanup() clean global state directory

[ https://issues.apache.org/jira/browse/KAFKA-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271390#comment-16271390 ] ASF GitHub Bot commented on KAFKA-6259: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4827) Kafka connect: error with special characters in connector name

[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271386#comment-16271386 ] ASF GitHub Bot commented on KAFKA-4827: --- Github user wicknicks closed the pull reque

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271380#comment-16271380 ] ASF GitHub Bot commented on KAFKA-6260: --- GitHub user hachikuji opened a pull request

[jira] [Commented] (KAFKA-6150) Make Repartition Topics Transient

[ https://issues.apache.org/jira/browse/KAFKA-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271351#comment-16271351 ] Guozhang Wang commented on KAFKA-6150: -- Yes, KAFKA-6038 can be closed as duplicate.

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271350#comment-16271350 ] ASF GitHub Bot commented on KAFKA-4499: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271352#comment-16271352 ] Jason Gustafson commented on KAFKA-6260: [~guozhang] The collection mentioned abov

[jira] [Resolved] (KAFKA-6038) Repartition topics could be much more transient

[ https://issues.apache.org/jira/browse/KAFKA-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6038. -- Resolution: Duplicate > Repartition topics could be much more transient > --

[jira] [Updated] (KAFKA-6282) exactly_once semantics breaks demo application

[ https://issues.apache.org/jira/browse/KAFKA-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Romans Markuns updated KAFKA-6282: -- Description: +What I try to achieve+ Do successful run of Kafka streams app with setting "proces

[jira] [Assigned] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4499: Assignee: Richard Yu > Add "getAllKeys" API for querying windowed KTable stores > -

[jira] [Commented] (KAFKA-6150) Make Repartition Topics Transient

[ https://issues.apache.org/jira/browse/KAFKA-6150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271345#comment-16271345 ] Matthias J. Sax commented on KAFKA-6150: Is this the same as KAFKA-6038 ? > Make

[jira] [Resolved] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4499. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4258 [https://githu

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271321#comment-16271321 ] Guozhang Wang commented on KAFKA-6260: -- Thanks for the investigation [~hachikuji]. Ju

[jira] [Updated] (KAFKA-4827) Kafka connect: error with special characters in connector name

[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4827: - Fix Version/s: 0.11.0.3 0.10.2.2 0.10.1.2

[jira] [Assigned] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6260: -- Assignee: Jason Gustafson > AbstractCoordinator not clearly handles NULL Exception > --

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271269#comment-16271269 ] Jason Gustafson commented on KAFKA-6260: I think I may have spotted a possible cau

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271190#comment-16271190 ] Colin P. McCabe commented on KAFKA-6260: Hi [~habdank], Can you try this pull req

[jira] [Commented] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations

[ https://issues.apache.org/jira/browse/KAFKA-6283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271165#comment-16271165 ] ASF GitHub Bot commented on KAFKA-6283: --- GitHub user tombentley opened a pull reques

[jira] [Commented] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations

[ https://issues.apache.org/jira/browse/KAFKA-6283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16271003#comment-16271003 ] Tom Bentley commented on KAFKA-6283: [~ijuma], [~rsivaram] this is a very minor change

[jira] [Created] (KAFKA-6283) Configuration of custom SCRAM SaslServer implementations

Tom Bentley created KAFKA-6283: -- Summary: Configuration of custom SCRAM SaslServer implementations Key: KAFKA-6283 URL: https://issues.apache.org/jira/browse/KAFKA-6283 Project: Kafka Issue Type

[jira] [Comment Edited] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270867#comment-16270867 ] Anil edited comment on KAFKA-6281 at 11/29/17 2:48 PM: --- Thanks Manik

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270867#comment-16270867 ] Anil commented on KAFKA-6281: - Thanks Manikumar. Is there any way that I can know the reason f

[jira] [Created] (KAFKA-6282) exactly_once semantics breaks demo application

Romans Markuns created KAFKA-6282: - Summary: exactly_once semantics breaks demo application Key: KAFKA-6282 URL: https://issues.apache.org/jira/browse/KAFKA-6282 Project: Kafka Issue Type: Bu

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270767#comment-16270767 ] Manikumar commented on KAFKA-6281: -- [~anilkumar...@gmail.com] 2mins is high value. increa

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270755#comment-16270755 ] Anil commented on KAFKA-6281: - Thanks for the suggestion [~omkreddy]. Will consider using the

[jira] [Comment Edited] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270588#comment-16270588 ] Manikumar edited comment on KAFKA-6281 at 11/29/17 10:56 AM: -

[jira] [Commented] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

[ https://issues.apache.org/jira/browse/KAFKA-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270588#comment-16270588 ] Manikumar commented on KAFKA-6281: -- looks ZK session expired on the broker. Whenever thi

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 8:59 AM: ---

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 8:58 AM: ---

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 8:55 AM: ---

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 8:54 AM: ---

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 8:52 AM: ---

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- [~mjsax] How can I

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 11/29/17 8:49 AM: ---

[jira] [Created] (KAFKA-6281) Kafka JavaAPI Producer failed with NotLeaderForPartitionException

Anil created KAFKA-6281: --- Summary: Kafka JavaAPI Producer failed with NotLeaderForPartitionException Key: KAFKA-6281 URL: https://issues.apache.org/jira/browse/KAFKA-6281 Project: Kafka Issue Type: Bu

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16270403#comment-16270403 ] Matthias J. Sax commented on KAFKA-5882: Thanks for the hint with KAFKA-6260 -- we