[jira] [Commented] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is inval

2017-11-27 Thread Michal Klempa (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268257#comment-16268257 ] Michal Klempa commented on KAFKA-6266: -- I ran into the situation, where my log segment is 0 in byt

[jira] [Commented] (KAFKA-3907) Better support for user-specific committing in the Streams DSL

2017-11-27 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16268084#comment-16268084 ] Richard Yu commented on KAFKA-3907: --- [~guozhang] Do you have any specific interface or class where one

[jira] [Created] (KAFKA-6278) Allow multiple concurrent transactions on a single producer

2017-11-27 Thread Tim Cuthbertson (JIRA)
Tim Cuthbertson created KAFKA-6278: -- Summary: Allow multiple concurrent transactions on a single producer Key: KAFKA-6278 URL: https://issues.apache.org/jira/browse/KAFKA-6278 Project: Kafka

[jira] [Created] (KAFKA-6277) Make loadClass thread-safe for class loaders of Connect plugins

2017-11-27 Thread Konstantine Karantasis (JIRA)
Konstantine Karantasis created KAFKA-6277: - Summary: Make loadClass thread-safe for class loaders of Connect plugins Key: KAFKA-6277 URL: https://issues.apache.org/jira/browse/KAFKA-6277

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

2017-11-27 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267904#comment-16267904 ] Jason Gustafson commented on KAFKA-6264: [~becket_qin] Good catch. For users who hit this, one

[jira] [Created] (KAFKA-6276) AdminClient may leave some futures hanging after shutdown

2017-11-27 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6276: -- Summary: AdminClient may leave some futures hanging after shutdown Key: KAFKA-6276 URL: https://issues.apache.org/jira/browse/KAFKA-6276 Project: Kafka

[jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

2017-11-27 Thread Panuwat Anawatmongkhon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267616#comment-16267616 ] Panuwat Anawatmongkhon commented on KAFKA-6138: --- OK, I got the permission. > Simplify

[jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

2017-11-27 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267601#comment-16267601 ] Guozhang Wang commented on KAFKA-6138: -- I saw that Jun has just granted you the permission, could you

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

2017-11-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267400#comment-16267400 ] ASF GitHub Bot commented on KAFKA-5117: --- GitHub user qiao-meng-zefr opened a pull request:

[jira] [Commented] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267305#comment-16267305 ] Vahid Hashemian commented on KAFKA-6275: [~hachikuji] Thanks for trying to push KIP-175 forward. I

[jira] [Commented] (KAFKA-6273) Allow names for windowing joins

2017-11-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267292#comment-16267292 ] Matthias J. Sax commented on KAFKA-6273: Thanks for the JIRA. All public API changes require a

[jira] [Commented] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267288#comment-16267288 ] Jason Gustafson commented on KAFKA-6275: [~vahid] Sure, makes sense to get in KIP-175 first (I'll

[jira] [Updated] (KAFKA-6273) Allow names for windowing joins

2017-11-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6273: --- Component/s: streams > Allow names for windowing joins > --- > >

[jira] [Updated] (KAFKA-6273) Allow names for windowing joins

2017-11-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6273: --- Labels: needs-kip (was: ) > Allow names for windowing joins >

[jira] [Updated] (KAFKA-6273) Allow names for windowing joins

2017-11-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6273: --- Affects Version/s: 1.0.0 > Allow names for windowing joins > ---

[jira] [Comment Edited] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267187#comment-16267187 ] Vahid Hashemian edited comment on KAFKA-6275 at 11/27/17 6:58 PM: -- The

[jira] [Commented] (KAFKA-6274) Improve KTable Source state store auto-generated names

2017-11-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267242#comment-16267242 ] ASF GitHub Bot commented on KAFKA-6274: --- GitHub user guozhangwang opened a pull request:

[jira] [Commented] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267187#comment-16267187 ] Vahid Hashemian commented on KAFKA-6275: This seems to also conflict with

[jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

2017-11-27 Thread Panuwat Anawatmongkhon (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267167#comment-16267167 ] Panuwat Anawatmongkhon commented on KAFKA-6138: --- [~guozhang] Can you grant me the permission

[jira] [Comment Edited] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267140#comment-16267140 ] Vahid Hashemian edited comment on KAFKA-6275 at 11/27/17 5:59 PM: --

[jira] [Commented] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267140#comment-16267140 ] Vahid Hashemian commented on KAFKA-6275: [~hachikuji] I'd like to work on this. Is it possible to

[jira] [Assigned] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-6275: -- Assignee: Vahid Hashemian > Extend consumer offset reset tool to support deletion >

[jira] [Created] (KAFKA-6275) Extend consumer offset reset tool to support deletion

2017-11-27 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6275: -- Summary: Extend consumer offset reset tool to support deletion Key: KAFKA-6275 URL: https://issues.apache.org/jira/browse/KAFKA-6275 Project: Kafka

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

2017-11-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267123#comment-16267123 ] Jun Rao commented on KAFKA-1120: [~mimaison], thanks for helping out! > Controller could miss a broker

[jira] [Updated] (KAFKA-6274) Improve KTable Source state store auto-generated names

2017-11-27 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6274: - Description: When the source KTable is generated without the store name specified, the

[jira] [Created] (KAFKA-6274) Improve KTable Source state store auto-generated names

2017-11-27 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6274: Summary: Improve KTable Source state store auto-generated names Key: KAFKA-6274 URL: https://issues.apache.org/jira/browse/KAFKA-6274 Project: Kafka Issue

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

2017-11-27 Thread Mickael Maison (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267107#comment-16267107 ] Mickael Maison commented on KAFKA-1120: --- [~junrao] Thanks for the confirmation, in that case I'll

[jira] [Assigned] (KAFKA-1120) Controller could miss a broker state change

2017-11-27 Thread Mickael Maison (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-1120: - Assignee: Mickael Maison > Controller could miss a broker state change >

[jira] [Updated] (KAFKA-6273) Allow names for windowing joins

2017-11-27 Thread Matthias (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated KAFKA-6273: Description: Currently, the internal name of a windowing join is generated at runtime using a counter to

[jira] [Created] (KAFKA-6273) Allow names for windowing joins

2017-11-27 Thread Matthias (JIRA)
Matthias created KAFKA-6273: --- Summary: Allow names for windowing joins Key: KAFKA-6273 URL: https://issues.apache.org/jira/browse/KAFKA-6273 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-11-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267029#comment-16267029 ] Manikumar commented on KAFKA-6199: -- [~rt_skyscanner] It should be safe to run this command. I have not

[jira] [Updated] (KAFKA-6272) SASL PLAIN and SCRAM do not apply SASLPrep

2017-11-27 Thread Tom Bentley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley updated KAFKA-6272: --- Description: [RFC 5802|https://tools.ietf.org/html/rfc5802] (SASL SCRAM) says: {quote} Before

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-11-27 Thread Robin Tweedie (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16267002#comment-16267002 ] Robin Tweedie commented on KAFKA-6199: -- [~omkreddy] Would this be safe to run against production?

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-11-27 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266985#comment-16266985 ] Manikumar commented on KAFKA-6199: -- Can you attach the output of of jmap command? {quote}jdk/bin/jmap

[jira] [Created] (KAFKA-6272) SASL PLAIN and SCRAM do not apply SASLPrep

2017-11-27 Thread Tom Bentley (JIRA)
Tom Bentley created KAFKA-6272: -- Summary: SASL PLAIN and SCRAM do not apply SASLPrep Key: KAFKA-6272 URL: https://issues.apache.org/jira/browse/KAFKA-6272 Project: Kafka Issue Type: Bug

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

2017-11-27 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266883#comment-16266883 ] Seweryn Habdank-Wojewodzki commented on KAFKA-6260: --- [~ijuma] Include some reproducible

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-11-27 Thread Robin Tweedie (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266760#comment-16266760 ] Robin Tweedie commented on KAFKA-6199: -- We tried to prove that this client was the culprit, but we

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

2017-11-27 Thread Mickael Maison (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266652#comment-16266652 ] Mickael Maison commented on KAFKA-1120: --- We've hit this issue ([KAFKA-3944]) a number of times in

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

2017-11-27 Thread Jonathan Skrzypek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266639#comment-16266639 ] Jonathan Skrzypek commented on KAFKA-6195: -- [~ijuma] Ok great. Could I get permissions on the

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

2017-11-27 Thread Andreas Schroeder (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266491#comment-16266491 ] Andreas Schroeder commented on KAFKA-6269: -- Hi [~mjsax], thanks for the swift response and your