[jira] [Updated] (KAFKA-1322) slow startup after unclean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Ozeritskiy updated KAFKA-1322: - Resolution: Won't Fix Status: Resolved (was: Patch Available) ok > slow startup

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945223#comment-13945223 ] Jason Rosenberg commented on KAFKA-1029: I'm starting to suspect my issue is actua

Re: Review Request 19388: Patch for KAFKA-1251

> On March 23, 2014, 11:57 p.m., Jun Rao wrote: > > Thanks for the patch. Some comments. > > > > 1. For producer level stats (ie., not node or topic level), for jmx beans, > > the package name becomes kafka.producer (since the bean name is > > kafka.producer:type=client-id). For the topic and

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/#review38306 --- I couldn't reproduce the shutdown problem where the DeleteTopicsThre

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945311#comment-13945311 ] Neha Narkhede commented on KAFKA-1029: -- [~jbrosenb...@gmail.com] It is a little diffi

Re: Review Request 19577: Patch for KAFKA-1317

> On March 24, 2014, 4:20 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/controller/TopicDeletionManager.scala, line 74 > > > > > > This is probably trying to fix the problem reported in KAFKA-1307? If > > ye

Re: Review Request 19577: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19577/ --- (Updated March 24, 2014, 6:06 p.m.) Review request for kafka. Bugs: KAFKA-131

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317_2014-03-24_11:06:15.patch > KafkaServer 0.8.1 not responding to .shutdown()

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945429#comment-13945429 ] Timothy Chen commented on KAFKA-1317: - Updated reviewboard https://reviews.apache.org/

[jira] [Created] (KAFKA-1323) log.dirs server property no longer supports relative directories

Joel Koshy created KAFKA-1323: - Summary: log.dirs server property no longer supports relative directories Key: KAFKA-1323 URL: https://issues.apache.org/jira/browse/KAFKA-1323 Project: Kafka Iss

[jira] [Commented] (KAFKA-1315) log.dirs property in KafkaServer intolerant of trailing slash

[ https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945460#comment-13945460 ] Joel Koshy commented on KAFKA-1315: --- This patch seems to have resulted in KAFKA-1323 >

[jira] [Commented] (KAFKA-1323) log.dirs server property no longer supports relative directories

[ https://issues.apache.org/jira/browse/KAFKA-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945469#comment-13945469 ] Joel Koshy commented on KAFKA-1323: --- {code} java.util.NoSuchElementException: key not fo

[jira] [Commented] (KAFKA-1323) log.dirs server property no longer supports relative directories

[ https://issues.apache.org/jira/browse/KAFKA-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13945532#comment-13945532 ] Neha Narkhede commented on KAFKA-1323: -- oops, this is my bad. Missed this during the

[jira] [Reopened] (KAFKA-1315) log.dirs property in KafkaServer intolerant of trailing slash

[ https://issues.apache.org/jira/browse/KAFKA-1315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reopened KAFKA-1315: -- > log.dirs property in KafkaServer intolerant of trailing slash > -

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (82 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1318 waiting for producer to stop is not reliable in system tests https://issues.apache.org/jira/browse/KAFKA-1318 KAFKA-1317

Re: Review Request 19388: Patch for KAFKA-1251

> On March 23, 2014, 11:57 p.m., Jun Rao wrote: > > Thanks for the patch. Some comments. > > > > 1. For producer level stats (ie., not node or topic level), for jmx beans, > > the package name becomes kafka.producer (since the bean name is > > kafka.producer:type=client-id). For the topic and

Re: Review Request 18299: Fix KAFKA-1253

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/18299/#review38386 --- clients/src/main/java/org/apache/kafka/clients/producer/internals/R

Re: Review Request 18299: Fix KAFKA-1253

> On March 24, 2014, 11:50 p.m., Jun Rao wrote: > > clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, > > lines 246-251 > > > > > > We can't just drop those records on the floo

Re: New Consumer API discussion

Hey Chris, Really sorry for the late reply, wonder how this fell through the cracks. Anyhow, thanks for the great feedback! Here are my comments - 1. Why is the config String->Object instead of String->String? This is probably more of a feedback about the new config management that we adopted in

Re: New Consumer API discussion

I took some time to write some example code using the new consumer APIs to cover a range of use cases. This exercise was very useful (thanks for the suggestion, Jay!) since I found several improvements to the APIs to make them more usable. Here are some of the changes

0.8.1.1 - rough ETA?

Hi, There was talk about 0.8.1.1 bugfix release about 10 days ago. Are there any rough ETAs for it? e.g. are you thinking next week or end of April? Sorry about the when question, just trying to plan our halted migration to Kafka 0.8.x Thanks, Otis -- Performance Monitoring * Log Analytics * Se

[jira] [Updated] (KAFKA-1323) log.dirs server property no longer supports relative directories

[ https://issues.apache.org/jira/browse/KAFKA-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1323: - Priority: Blocker (was: Major) > log.dirs server property no longer supports relative directorie

Re: Review Request 19388: Patch for KAFKA-1251

> On March 23, 2014, 11:57 p.m., Jun Rao wrote: > > Thanks for the patch. Some comments. > > > > 1. For producer level stats (ie., not node or topic level), for jmx beans, > > the package name becomes kafka.producer (since the bean name is > > kafka.producer:type=client-id). For the topic and

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13946076#comment-13946076 ] Sam Meder commented on KAFKA-1029: -- We've seen this as well (once or twice in ~4 months).

Question about manual tracking of Offset

Hi experts & Kafka Dev team, Have a very quick question and need your help in designing a consumer. I am trying to keep the email short and simple. Scenario, Lets say: 1) Have a Kafka with 20 messages(from Offset 0 - 19) 2) Pulling the 1st 10 message from 0th to 9th Offset(assuming the desired

Question about manual tracking of Offset

Hi experts & Kafka Dev team, Have a very quick question and need your help in designing a consumer. I am trying to keep the email short and simple. Scenario, Lets say: 1) Have a Kafka with 20 messages(from Offset 0 - 19) 2) Pulling the 1st 10 message from 0th to 9th Offset(assuming the desired