[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=16270867#comment-16270867 ] Anil edited comment on KAFKA-6281 at 11/30/17 5:32 AM: --- Thanks [~omkreddy].. Is

[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=16272142#comment-16272142 ] Nick Travers commented on KAFKA-4669: - [~hachikuji] - unfortunately, we only have the stack trace

[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=16272013#comment-16272013 ] Matthias J. Sax edited comment on KAFKA-6269 at 11/30/17 1:56 AM: -- About

[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=16272013#comment-16272013 ] Matthias J. Sax commented on KAFKA-6269: About the workaround. You could mask {{null}} with a

[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=16272013#comment-16272013 ] Matthias J. Sax edited comment on KAFKA-6269 at 11/30/17 1:55 AM: -- About

[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

[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=16271920#comment-16271920 ] ASF GitHub Bot commented on KAFKA-5936: --- Github user asfgit closed the pull request at:

[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=16271906#comment-16271906 ] aarti gupta commented on KAFKA-4669: unfortunately we did not have trace enabled and did not enable it

[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=16271902#comment-16271902 ] Jason Gustafson commented on KAFKA-4669: [~aartigupta] The consumer logs would probably be more

[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=16271894#comment-16271894 ] aarti gupta edited comment on KAFKA-4669 at 11/30/17 12:32 AM: --- [~hachikuji]

[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=16271894#comment-16271894 ] aarti gupta commented on KAFKA-4669: [~hachikuji] I can send you the zookeeper and kafka server

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

[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=16271832#comment-16271832 ] Jason Gustafson commented on KAFKA-4669: [~nickt] [~aartigupta] Do either of you have client logs?

[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=16271827#comment-16271827 ] Jason Gustafson commented on KAFKA-4669: Reopened since there are two reported cases on 0.11.0.1.

[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

[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=16271727#comment-16271727 ] aarti gupta edited comment on KAFKA-4669 at 11/29/17 11:01 PM: --- We saw this

[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=16271727#comment-16271727 ] aarti gupta commented on KAFKA-4669: We saw this in production today ERROR

[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=16271488#comment-16271488 ] Ramkumar commented on KAFKA-6227: - I think I found the kafka behavior that may cause the issue. Please

[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=16271405#comment-16271405 ] Matthias J. Sax commented on KAFKA-5882: The JIRA is marked for {{0.11.0.0}}: there,

[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=16271400#comment-16271400 ] Jason Gustafson commented on KAFKA-6260: [~habdank] If possible, can you test with the patch

[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=16271399#comment-16271399 ] Guozhang Wang commented on KAFKA-6269: -- [~andreas-schroeder] We have spotted the regression bug

[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=16271398#comment-16271398 ] Matthias J. Sax commented on KAFKA-6282: Transactions by default require a replication factor of

[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=16271393#comment-16271393 ] Guozhang Wang commented on KAFKA-6260: -- Ack, thanks!! > AbstractCoordinator not clearly handles NULL

[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=16271391#comment-16271391 ] ASF GitHub Bot commented on KAFKA-4827: --- Github user wicknicks closed the pull request at:

[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=16271390#comment-16271390 ] ASF GitHub Bot commented on KAFKA-6259: --- Github user asfgit closed the pull request at:

[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=16271386#comment-16271386 ] ASF GitHub Bot commented on KAFKA-4827: --- Github user wicknicks closed the pull request at:

[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=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=16271351#comment-16271351 ] Guozhang Wang commented on KAFKA-6150: -- Yes, KAFKA-6038 can be closed as duplicate. > Make

[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=16271350#comment-16271350 ] ASF GitHub Bot commented on KAFKA-4499: --- Github user asfgit closed the pull request at:

[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=16271352#comment-16271352 ] Jason Gustafson commented on KAFKA-6260: [~guozhang] The collection mentioned above was only

[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

[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=16271345#comment-16271345 ] Matthias J. Sax commented on KAFKA-6150: Is this the same as KAFKA-6038 ? > Make Repartition

[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

[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=16271321#comment-16271321 ] Guozhang Wang commented on KAFKA-6260: -- Thanks for the investigation [~hachikuji]. Just curious if

[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=16271269#comment-16271269 ] Jason Gustafson commented on KAFKA-6260: I think I may have spotted a possible cause.

[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=16271190#comment-16271190 ] Colin P. McCabe commented on KAFKA-6260: Hi [~habdank], Can you try this pull request to see if

[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=16271165#comment-16271165 ] ASF GitHub Bot commented on KAFKA-6283: --- GitHub user tombentley opened a pull request:

[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=16271003#comment-16271003 ] Tom Bentley commented on KAFKA-6283: [~ijuma], [~rsivaram] this is a very minor change, but I suppose

[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

[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=16270867#comment-16270867 ] Anil edited comment on KAFKA-6281 at 11/29/17 2:48 PM: --- Thanks Manikumar. Is there

[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=16270867#comment-16270867 ] Anil commented on KAFKA-6281: - Thanks Manikumar. Is there any way that I can know the reason for time-out, by

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

[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=16270767#comment-16270767 ] Manikumar commented on KAFKA-6281: -- [~anilkumar...@gmail.com] 2mins is high value. increasing further may

[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=16270755#comment-16270755 ] Anil commented on KAFKA-6281: - Thanks for the suggestion [~omkreddy]. Will consider using the idempotent

[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=16270588#comment-16270588 ] Manikumar edited comment on KAFKA-6281 at 11/29/17 10:56 AM: - looks like ZK

[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=16270588#comment-16270588 ] Manikumar commented on KAFKA-6281: -- looks ZK session expired on the broker. Whenever this happens, you

[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=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=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=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=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=16270420#comment-16270420 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- [~mjsax] How can I get result

[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=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:

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

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