[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099537#comment-16099537 ] ASF GitHub Bot commented on KAFKA-5611: --- GitHub user hachikuji opened a pull request

[jira] [Commented] (KAFKA-4218) Enable access to key in ValueTransformer

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099492#comment-16099492 ] ASF GitHub Bot commented on KAFKA-4218: --- Github user jeyhunkarimov closed the pull r

[jira] [Commented] (KAFKA-4218) Enable access to key in ValueTransformer

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099491#comment-16099491 ] ASF GitHub Bot commented on KAFKA-4218: --- GitHub user jeyhunkarimov opened a pull req

[jira] [Commented] (KAFKA-5634) Replica fetcher thread crashes due to OffsetOutOfRangeException

2017-07-24 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099470#comment-16099470 ] Jason Gustafson commented on KAFKA-5634: Should have mentioned this, but the speci

[jira] [Created] (KAFKA-5634) Replica fetcher thread crashes due to OffsetOutOfRangeException

2017-07-24 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-5634: -- Summary: Replica fetcher thread crashes due to OffsetOutOfRangeException Key: KAFKA-5634 URL: https://issues.apache.org/jira/browse/KAFKA-5634 Project: Kafka

[jira] [Resolved] (KAFKA-5616) unable perform a rolling upgrade from a non-secure to a secure Kafka cluster

2017-07-24 Thread zhu fangbo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhu fangbo resolved KAFKA-5616. --- Resolution: Not A Problem This is due to improper ACL configuration,I did not set the operation for ea

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Bart Vercammen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16099058#comment-16099058 ] Bart Vercammen commented on KAFKA-5386: --- [~mjsax] {{--changelog}} that's exactly the

[jira] [Created] (KAFKA-5633) Clarify another scenario of unclean leader election

2017-07-24 Thread Ivan Babrou (JIRA)
Ivan Babrou created KAFKA-5633: -- Summary: Clarify another scenario of unclean leader election Key: KAFKA-5633 URL: https://issues.apache.org/jira/browse/KAFKA-5633 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-5630: --- Assignee: Jiangjie Qin > Consumer poll loop over the same record after a CorruptRecordExcepti

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098990#comment-16098990 ] Jiangjie Qin commented on KAFKA-5630: - [~vmaurin_glispa] Thanks for reporting the issu

[jira] [Commented] (KAFKA-4711) Change Default unclean.leader.election.enabled from True to False (KIP-106)

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098987#comment-16098987 ] ASF GitHub Bot commented on KAFKA-4711: --- GitHub user bobrik opened a pull request:

[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2017-07-24 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098973#comment-16098973 ] Jason Gustafson commented on KAFKA-5611: [~pskianis] You'd have to get pretty unli

[jira] [Assigned] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2017-07-24 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-5611: -- Assignee: Jason Gustafson > One or more consumers in a consumer-group stop consuming af

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

2017-07-24 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098929#comment-16098929 ] Guozhang Wang commented on KAFKA-4750: -- [~evis] That is right, we can go with the fir

[jira] [Reopened] (KAFKA-3856) Cleanup Kafka Streams builder API

2017-07-24 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-3856: -- Leave the JIRA as open since I think there is another PR coming for it. BTW moving forward it's bet

[jira] [Commented] (KAFKA-3856) Cleanup Kafka Streams builder API

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098914#comment-16098914 ] ASF GitHub Bot commented on KAFKA-3856: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-5632) Message headers not supported by Kafka Streams

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5632: --- Labels: needs-kip (was: ) > Message headers not supported by Kafka Streams >

[jira] [Comment Edited] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098591#comment-16098591 ] Matthias J. Sax edited comment on KAFKA-5386 at 7/24/17 3:39 PM: ---

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098591#comment-16098591 ] Matthias J. Sax commented on KAFKA-5386: Well. With regard to ACL, you can still k

[jira] [Updated] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5386: --- Labels: needs-kip (was: ) > [Kafka Streams] - custom name for state-store change-log topic >

[jira] [Updated] (KAFKA-5632) Message headers not supported by Kafka Streams

2017-07-24 Thread CJ Woolard (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CJ Woolard updated KAFKA-5632: -- Description: The new message headers functionality introduced in Kafka 0.11.0.0 (https://cwiki.apache.o

[jira] [Created] (KAFKA-5632) Message headers not supported by Kafka Streams

2017-07-24 Thread CJ Woolard (JIRA)
CJ Woolard created KAFKA-5632: - Summary: Message headers not supported by Kafka Streams Key: KAFKA-5632 URL: https://issues.apache.org/jira/browse/KAFKA-5632 Project: Kafka Issue Type: Bug

[jira] [Comment Edited] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Bart Vercammen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098554#comment-16098554 ] Bart Vercammen edited comment on KAFKA-5386 at 7/24/17 3:18 PM:

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-24 Thread Bart Vercammen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098554#comment-16098554 ] Bart Vercammen commented on KAFKA-5386: --- [~mjsax] Thanks for the reply. The `throug

[jira] [Updated] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5630: --- Labels: regression reliability (was: reliability) > Consumer poll loop over the same record after a C

[jira] [Updated] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5630: --- Priority: Critical (was: Major) > Consumer poll loop over the same record after a CorruptRecordExcept

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098279#comment-16098279 ] Ismael Juma commented on KAFKA-5630: Oh, I see. That's definitely a bug, you should be

[jira] [Updated] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5630: --- Labels: reliability (was: ) > Consumer poll loop over the same record after a CorruptRecordException

[jira] [Updated] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5630: --- Fix Version/s: 0.11.0.1 > Consumer poll loop over the same record after a CorruptRecordException > ---

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098276#comment-16098276 ] Vincent Maurin commented on KAFKA-5630: --- And I haven't noticed any other issues so f

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098263#comment-16098263 ] Vincent Maurin commented on KAFKA-5630: --- [~ijuma] thank you for your feedback. Regar

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098254#comment-16098254 ] Ismael Juma commented on KAFKA-5630: Have you had any other issues since the rolling u

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098253#comment-16098253 ] Ismael Juma commented on KAFKA-5630: [~vmaurin_glispa], the consumer behaviour is as e

[jira] [Commented] (KAFKA-5629) Console Consumer overrides auto.offset.reset property when provided on the command line without warning about it.

2017-07-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098230#comment-16098230 ] ASF GitHub Bot commented on KAFKA-5629: --- GitHub user soenkeliebau opened a pull requ

[jira] [Commented] (KAFKA-5631) Use Jackson for serialising to JSON

2017-07-24 Thread Umesh Chaudhary (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098221#comment-16098221 ] Umesh Chaudhary commented on KAFKA-5631: [~ijuma], assigning this to myself and wi

[jira] [Assigned] (KAFKA-5631) Use Jackson for serialising to JSON

2017-07-24 Thread Umesh Chaudhary (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-5631: -- Assignee: Umesh Chaudhary > Use Jackson for serialising to JSON > -

[jira] [Created] (KAFKA-5631) Use Jackson for serialising to JSON

2017-07-24 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-5631: -- Summary: Use Jackson for serialising to JSON Key: KAFKA-5631 URL: https://issues.apache.org/jira/browse/KAFKA-5631 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-1595) Remove deprecated and slower scala JSON parser

2017-07-24 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1595: --- Summary: Remove deprecated and slower scala JSON parser (was: Remove deprecated and slower scala JSON

[jira] [Comment Edited] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098154#comment-16098154 ] Vincent Maurin edited comment on KAFKA-5630 at 7/24/17 9:44 AM:

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098154#comment-16098154 ] Vincent Maurin commented on KAFKA-5630: --- It is ``` offset: 210648 position: 17215605

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098134#comment-16098134 ] huxihx commented on KAFKA-5630: --- Seems it's a duplicate of [KAFKA-5431|https://issues.apach

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098129#comment-16098129 ] Vincent Maurin commented on KAFKA-5630: --- A rolling upgrade from 0.10.2.0 has also be

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098124#comment-16098124 ] Vincent Maurin commented on KAFKA-5630: --- Just checking and it seems not. I don't hav

[jira] [Commented] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098117#comment-16098117 ] huxihx commented on KAFKA-5630: --- Did you enable `preallocate` for the topic? > Consumer pol

[jira] [Created] (KAFKA-5630) Consumer poll loop over the same record after a CorruptRecordException

2017-07-24 Thread Vincent Maurin (JIRA)
Vincent Maurin created KAFKA-5630: - Summary: Consumer poll loop over the same record after a CorruptRecordException Key: KAFKA-5630 URL: https://issues.apache.org/jira/browse/KAFKA-5630 Project: Kafka

[jira] [Commented] (KAFKA-5296) Unable to write to some partitions of newly created topic in 10.2

2017-07-24 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098063#comment-16098063 ] huxihx commented on KAFKA-5296: --- There is only one active controller in a cluster. How did y