[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

2018-11-13 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684871#comment-16684871 ] Sebastian Puzoń commented on KAFKA-7531: I kept running new version of stream app

[jira] [Comment Edited] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

2018-11-13 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684871#comment-16684871 ] Sebastian Puzoń edited comment on KAFKA-7531 at 11/13/18 8:32 AM: -

[jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow

2018-11-13 Thread Srinivas Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685102#comment-16685102 ] Srinivas Reddy commented on KAFKA-7446: --- Hi [~jlaskowski], Are you working on this?

[jira] [Assigned] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter

2018-11-13 Thread Srinivas Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Reddy reassigned KAFKA-7606: - Assignee: Srinivas Reddy > Remove deprecated --zookeeper option from StreamsResetter > -

[jira] [Assigned] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow

2018-11-13 Thread Srinivas Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Reddy reassigned KAFKA-7446: - Assignee: Srinivas Reddy > Better error message to explain the upper limit of TimeWindow

[jira] [Created] (KAFKA-7621) Clients can't deal with server IP address change

2018-11-13 Thread Bastian Voigt (JIRA)
Bastian Voigt created KAFKA-7621: Summary: Clients can't deal with server IP address change Key: KAFKA-7621 URL: https://issues.apache.org/jira/browse/KAFKA-7621 Project: Kafka Issue Type: Bu

[jira] [Commented] (KAFKA-7618) Trogdor - Fix /tasks endpoint parameters

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685453#comment-16685453 ] ASF GitHub Bot commented on KAFKA-7618: --- cmccabe closed pull request #5905: KAFKA-7

[jira] [Commented] (KAFKA-7514) Trogdor - Support Multiple Threads in ConsumeBenchWorker

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685457#comment-16685457 ] ASF GitHub Bot commented on KAFKA-7514: --- cmccabe closed pull request #5864: KAFKA-7

[jira] [Created] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Di Campo (JIRA)
Di Campo created KAFKA-7622: --- Summary: Add findSessions functionality to ReadOnlySessionStore Key: KAFKA-7622 URL: https://issues.apache.org/jira/browse/KAFKA-7622 Project: Kafka Issue Type: New Fe

[jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-7622: Description: When creating a session store from the DSL, and you get a  {{ReadOnlySessionStore}}, you can f

[jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7622: --- Labels: needs-kip (was: needs-k) > Add findSessions functionality to ReadOnlySessionStore >

[jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7622: --- Labels: needs-k (was: ) > Add findSessions functionality to ReadOnlySessionStore > -

[jira] [Commented] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685508#comment-16685508 ] Bill Bejeck commented on KAFKA-7622: Hi [~xmar], this seems like a useful feature. 

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685591#comment-16685591 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Yeah, it's a good point t

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685591#comment-16685591 ] Jason Gustafson edited comment on KAFKA-7610 at 11/13/18 6:47 PM: -

[jira] [Commented] (KAFKA-7080) WindowStoreBuilder incorrectly initializes CachingWindowStore

2018-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685639#comment-16685639 ] Guozhang Wang commented on KAFKA-7080: -- [~vvcephei] I checked all the four related P

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

2018-11-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685647#comment-16685647 ] Guozhang Wang commented on KAFKA-4601: -- cc [~bbejeck]. I think we can resolve this t

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

2018-11-13 Thread Kamal Kang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685746#comment-16685746 ] Kamal Kang commented on KAFKA-6812: --- [~enether] - [https://cwiki.apache.org/confluence

[jira] [Commented] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter

2018-11-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685783#comment-16685783 ] Matthias J. Sax commented on KAFKA-7606: [~mrsrinivas] Thanks for picking this up

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685810#comment-16685810 ] Boyang Chen commented on KAFKA-7610: [~hachikuji] So we will still accept unknown mem

[jira] [Updated] (KAFKA-7601) Handle message format downgrades during upgrade of message format version

2018-11-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7601: --- Description: During an upgrade of the message format, there is a short time during which the

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685884#comment-16685884 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Hmm.. Good question. Perh

[jira] [Commented] (KAFKA-7621) Clients can't deal with server IP address change

2018-11-13 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685918#comment-16685918 ] Edoardo Comar commented on KAFKA-7621: -- Hi, have you tried to set *networkaddress.ca

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685961#comment-16685961 ] Boyang Chen commented on KAFKA-7610: [~hachikuji] I see your point. > a simple way t

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685961#comment-16685961 ] Boyang Chen edited comment on KAFKA-7610 at 11/14/18 1:04 AM: -

[jira] [Resolved] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

2018-11-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-4601. Resolution: Fixed Marking this resolved with [https://github.com/apache/kafka/pull/5451.] As [~guo

[jira] [Commented] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter

2018-11-13 Thread Srinivas Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686073#comment-16686073 ] Srinivas Reddy commented on KAFKA-7606: --- Thank you [~mjsax] for information. Yes, I

[jira] [Created] (KAFKA-7623) SMT STRUCT to MASK or FILTER

2018-11-13 Thread Chenchu Lakshman kumar (JIRA)
Chenchu Lakshman kumar created KAFKA-7623: - Summary: SMT STRUCT to MASK or FILTER Key: KAFKA-7623 URL: https://issues.apache.org/jira/browse/KAFKA-7623 Project: Kafka Issue Type: Test