[jira] [Commented] (KAFKA-881) Kafka broker not respecting log.roll.hours

[ https://issues.apache.org/jira/browse/KAFKA-881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786925#comment-13786925 ] Dan F commented on KAFKA-881: - Sure enough, that's a race condition. Practically speaking, it n

[jira] [Commented] (KAFKA-966) Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message

[ https://issues.apache.org/jira/browse/KAFKA-966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786833#comment-13786833 ] Neha Narkhede commented on KAFKA-966: - Yes, it should. > Allow high level consumer to

Re: Review Request 14496: Patch for KAFKA-1073

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14496/#review26704 --- Thanks for the patch. I also think deprecating this and adding a --v

Re: Review Request 14496: Patch for KAFKA-1073

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14496/#review26703 --- Ship it! Agree with Swapnil. - Guozhang Wang On Oct. 4, 2013, 9:

[jira] [Updated] (KAFKA-1075) Consumer will not rebalance upon topic partition change

[ https://issues.apache.org/jira/browse/KAFKA-1075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1075: - Attachment: KAFKA-1075.patch > Consumer will not rebalance upon topic partition change >

[jira] [Commented] (KAFKA-1075) Consumer will not rebalance upon topic partition change

[ https://issues.apache.org/jira/browse/KAFKA-1075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786692#comment-13786692 ] Guozhang Wang commented on KAFKA-1075: -- Created reviewboard https://reviews.apache.or

Review Request 14497: Patch for KAFKA-1075

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14497/ --- Review request for kafka. Bugs: KAFKA-1075 https://issues.apache.org/jira/b

[jira] [Created] (KAFKA-1075) Consumer will not rebalance upon topic partition change

Guozhang Wang created KAFKA-1075: Summary: Consumer will not rebalance upon topic partition change Key: KAFKA-1075 URL: https://issues.apache.org/jira/browse/KAFKA-1075 Project: Kafka Issue T

Re: Review Request 14496: Patch for KAFKA-1073

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14496/#review26701 --- Ship it! Do you think incorporating this functionality in the Reass

[jira] [Created] (KAFKA-1074) Reassign partitions should delete the old replicas from disk

Jun Rao created KAFKA-1074: -- Summary: Reassign partitions should delete the old replicas from disk Key: KAFKA-1074 URL: https://issues.apache.org/jira/browse/KAFKA-1074 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-1073) CheckReassignmentStatus is broken

[ https://issues.apache.org/jira/browse/KAFKA-1073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1073: --- Status: Patch Available (was: Open) > CheckReassignmentStatus is broken > -

Review Request 14496: Patch for KAFKA-1073

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14496/ --- Review request for kafka. Bugs: KAFKA-1073 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1073) CheckReassignmentStatus is broken

[ https://issues.apache.org/jira/browse/KAFKA-1073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786649#comment-13786649 ] Jun Rao commented on KAFKA-1073: Created reviewboard https://reviews.apache.org/r/14496/

[jira] [Updated] (KAFKA-1073) CheckReassignmentStatus is broken

[ https://issues.apache.org/jira/browse/KAFKA-1073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1073: --- Attachment: KAFKA-1073.patch > CheckReassignmentStatus is broken > - > >

[jira] [Created] (KAFKA-1073) CheckReassignmentStatus is broken

Jun Rao created KAFKA-1073: -- Summary: CheckReassignmentStatus is broken Key: KAFKA-1073 URL: https://issues.apache.org/jira/browse/KAFKA-1073 Project: Kafka Issue Type: Bug Components: cor

[jira] [Commented] (KAFKA-966) Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message

[ https://issues.apache.org/jira/browse/KAFKA-966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786481#comment-13786481 ] Jason Rosenberg commented on KAFKA-966: --- Cool, Will this work for consumers set up t

[jira] [Commented] (KAFKA-966) Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message

[ https://issues.apache.org/jira/browse/KAFKA-966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786307#comment-13786307 ] Neha Narkhede commented on KAFKA-966: - Jason, You might want to check out the new prop

[jira] [Commented] (KAFKA-881) Kafka broker not respecting log.roll.hours

[ https://issues.apache.org/jira/browse/KAFKA-881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786295#comment-13786295 ] Jun Rao commented on KAFKA-881: --- Thanks for the patch. I am not sure if the patch works thoug

[jira] [Commented] (KAFKA-881) Kafka broker not respecting log.roll.hours

[ https://issues.apache.org/jira/browse/KAFKA-881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13786084#comment-13786084 ] Dan F commented on KAFKA-881: - Any word on whether this will be accepted into 0.7 and 0.8? It w