[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] [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=16685102#comment-16685102 ] Srinivas Reddy commented on KAFKA-7446: --- Hi [~jlaskowski], Are you working on this? Should I pick

[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

[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=16684871#comment-16684871 ] Sebastian Puzoń commented on KAFKA-7531: I kept running new version of stream application that

[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=16685453#comment-16685453 ] ASF GitHub Bot commented on KAFKA-7618: --- cmccabe closed pull request #5905: KAFKA-7618: Fix

[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

[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] [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] [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=16685961#comment-16685961 ] Boyang Chen edited comment on KAFKA-7610 at 11/14/18 1:04 AM: -- [~hachikuji]

[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=16685961#comment-16685961 ] Boyang Chen commented on KAFKA-7610: [~hachikuji] I see your point. > a simple way to limit the

[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 

[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=16685918#comment-16685918 ] Edoardo Comar commented on KAFKA-7621: -- Hi, have you tried to set *networkaddress.cache.ttl ?* see 

[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=16685783#comment-16685783 ] Matthias J. Sax commented on KAFKA-7606: [~mrsrinivas] Thanks for picking this up. Note that we

[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=16685810#comment-16685810 ] Boyang Chen commented on KAFKA-7610: [~hachikuji] So we will still accept unknown member joining 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=16685884#comment-16685884 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Hmm.. Good question. Perhaps a simple way

[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=16686073#comment-16686073 ] Srinivas Reddy commented on KAFKA-7606: --- Thank you [~mjsax] for information. Yes, I will start

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

[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=16685746#comment-16685746 ] Kamal Kang commented on KAFKA-6812: --- [~enether] -

[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

[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=16685508#comment-16685508 ] Bill Bejeck commented on KAFKA-7622: Hi [~xmar], this seems like a useful feature.  Please note that

[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=16685591#comment-16685591 ] Jason Gustafson commented on KAFKA-7610: [~bchen225242] Yeah, it's a good point that static

[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=16685591#comment-16685591 ] Jason Gustafson edited comment on KAFKA-7610 at 11/13/18 6:47 PM: --

[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=16685647#comment-16685647 ] Guozhang Wang commented on KAFKA-4601: -- cc [~bbejeck]. I think we can resolve this ticket for now --

[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=16685639#comment-16685639 ] Guozhang Wang commented on KAFKA-7080: -- [~vvcephei] I checked all the four related PRs and it seems