[jira] [Commented] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state

[ https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13808133#comment-13808133 ] Jay Kreps commented on KAFKA-1106: -- Do you have the highwatermark checkpoint file that ca

Re: Review Request 14898: Patch for KAFKA-1060

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14898/#review27694 --- I got NPEs while running unit tests with this patch on trunk - [201

Re: Review Request 14730: KAFKA-1001 v4

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14730/#review27677 --- core/src/main/scala/kafka/server/AbstractFetcherManager.scala

Re: Review Request 14865: Patch for KAFKA-1097

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14865/ --- (Updated Oct. 29, 2013, 5:49 p.m.) Review request for kafka. Bugs: KAFKA-1097

[jira] [Updated] (KAFKA-1097) Race condition while reassigning low throughput partition leads to incorrect ISR information in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1097: - Attachment: KAFKA-1097_2013-10-29_10:49:45.patch > Race condition while reassigning low throughpu

[jira] [Commented] (KAFKA-1097) Race condition while reassigning low throughput partition leads to incorrect ISR information in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13808228#comment-13808228 ] Neha Narkhede commented on KAFKA-1097: -- Updated reviewboard https://reviews.apache.or

0.8 Head: Simple consumer no receiving messages

Hi, I see the following scenario: 1. Send messages under some topic X, able to see the log folder in Kafka Broker with name X-0 (Zeroth partition) and having files xxx.log and xxx.index under them. So guess this is fine 2. THen I fire up the consumer for topic X, it is able to find two streams

Re: Review Request 14865: Patch for KAFKA-1097

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14865/#review27702 --- core/src/main/scala/kafka/controller/KafkaController.scala

Re: Review Request 14898: Small bug fix

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14898/ --- (Updated Oct. 29, 2013, 6:12 p.m.) Review request for kafka. Summary (updated

[jira] [Commented] (KAFKA-1060) Break-down sendTime into responseQueueTime and the real sendTime

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

[jira] [Updated] (KAFKA-1060) Break-down sendTime into responseQueueTime and the real sendTime

[ https://issues.apache.org/jira/browse/KAFKA-1060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1060: - Attachment: KAFKA-1060_2013-10-29_11:12:45.patch > Break-down sendTime into responseQueueTime and

[jira] [Created] (KAFKA-1107) Broker recovers all log segments on an uncontrolled shutdown

Neha Narkhede created KAFKA-1107: Summary: Broker recovers all log segments on an uncontrolled shutdown Key: KAFKA-1107 URL: https://issues.apache.org/jira/browse/KAFKA-1107 Project: Kafka I

[jira] [Updated] (KAFKA-1107) Broker recovers all log segments on an uncontrolled shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1107: - Priority: Blocker (was: Critical) > Broker recovers all log segments on an uncontrolled shutdown

Re: Review Request 14730: Patch for KAFKA-1001

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14730/ --- (Updated Oct. 29, 2013, 6:27 p.m.) Review request for kafka. Summary (updated

[jira] [Commented] (KAFKA-1001) Handle follower transition in batch

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

[jira] [Updated] (KAFKA-1001) Handle follower transition in batch

[ https://issues.apache.org/jira/browse/KAFKA-1001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1001: - Attachment: KAFKA-1001_2013-10-29_11:27:20.patch > Handle follower transition in batch >

[jira] [Resolved] (KAFKA-1001) Handle follower transition in batch

[ https://issues.apache.org/jira/browse/KAFKA-1001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1001. Resolution: Fixed Thanks for the latest patch. +1 and committed to trunk. > Handle follower transition in

[jira] [Created] (KAFKA-1108) when controlled shutdown attempt fails, the reason is not always logged

Jason Rosenberg created KAFKA-1108: -- Summary: when controlled shutdown attempt fails, the reason is not always logged Key: KAFKA-1108 URL: https://issues.apache.org/jira/browse/KAFKA-1108 Project: Ka

Re: Review Request 14865: Patch for KAFKA-1097

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14865/#review27724 --- core/src/main/scala/kafka/cluster/Partition.scala

Re: Confluence wiki not editable

Hello Joe, Is there way I (as a non-committer) can create/edit a new wiki page today? What is the process I need to follow to be authorized? Guozhang On Mon, Oct 7, 2013 at 5:39 PM, Neha Narkhede wrote: > +1 on Sriram's suggestion. I'm in favor of all registered kafka users on > the mailing li

Re: Confluence wiki not editable

Hi Guozhang, let me open an infrastructure ticket to get a kafka-contributor added to the permissions, I tried and I only have space admin access. Access to the group will require an ICLA http://www.apache.org/licenses/#clas /*** Joe Stein Founder, Princi

Re: Confluence wiki not editable

Thanks! Shall I sign the ICLA and email you the electronic copy then? Guozhang On Tue, Oct 29, 2013 at 2:42 PM, Joe Stein wrote: > Hi Guozhang, let me open an infrastructure ticket to get a > kafka-contributor added to the permissions, I tried and I only have space > admin access. > > Access t

[jira] [Commented] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state

[ https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13808510#comment-13808510 ] David Lao commented on KAFKA-1106: -- Unfortunately the logs are no longer available but I

Re: Confluence wiki not editable

The email to send to is in the ICLA http://www.apache.org/licenses/icla.txt Here is the ticket https://issues.apache.org/jira/browse/INFRA-6947 for a kafka-contributor group for the wiki I have another also open for the 0.8.0 release https://issues.apache.org/jira/browse/INFRA-6927 still pending

Re: 0.8 Head: Simple consumer no receiving messages

The default behavior of the consumer is to consume from the tail of the partition log, did you continue processing data after the consumers have created their streams? Guozhang On Tue, Oct 29, 2013 at 10:52 AM, Shafaq wrote: > Hi, >I see the following scenario: > > 1. Send messages under s

Re: Confluence wiki not editable

Joe, I'm a committer but I'm not able to edit the wiki as well. Thanks, Neha On Tue, Oct 29, 2013 at 2:59 PM, Joe Stein wrote: > The email to send to is in the ICLA > http://www.apache.org/licenses/icla.txt > > Here is the ticket https://issues.apache.org/jira/browse/INFRA-6947 for a > kafka-

Re: Confluence wiki not editable

Neha, what is your username on the wiki? This way I can verify you have the right permissions and setup. Guozhang, what is your username on the wiki? Let me know once your ICLA is also in and I can add your permissions one-by-one is fine ok by me, np. /***

[jira] [Commented] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state

[ https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13808715#comment-13808715 ] Jay Kreps commented on KAFKA-1106: -- Is there any chance the file was manually modified? I

[jira] [Commented] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state

[ https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13808741#comment-13808741 ] David Lao commented on KAFKA-1106: -- No there is no chance of manual intervention. However

[jira] [Updated] (KAFKA-1108) when controlled shutdown attempt fails, the reason is not always logged

[ https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1108: - Fix Version/s: 0.8.1 > when controlled shutdown attempt fails, the reason is not always logged >

[jira] [Commented] (KAFKA-1106) HighwaterMarkCheckpoint failure puting broker into a bad state

[ https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13808761#comment-13808761 ] Jay Kreps commented on KAFKA-1106: -- Yeah a corrupted offset file would lead to this (but