[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-15 Thread Vladimir Tretyakov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173425#comment-14173425 ] Vladimir Tretyakov commented on KAFKA-1481: --- Hi Jun, thx for juicy feedback, few

[jira] [Commented] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173368#comment-14173368 ] Bhavesh Mistry commented on KAFKA-1710: --- Here is property file used for testing: {c

[jira] [Comment Edited] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173368#comment-14173368 ] Bhavesh Mistry edited comment on KAFKA-1710 at 10/16/14 4:54 AM: ---

[jira] [Comment Edited] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173344#comment-14173344 ] Bhavesh Mistry edited comment on KAFKA-1710 at 10/16/14 4:40 AM: ---

Re: [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry
Hi Jun, I have entered all details into https://issues.apache.org/jira/browse/KAFKA-1710. Let me know if you need more details. Thanks, Bhavesh On Wed, Oct 15, 2014 at 8:35 PM, Jun Rao wrote: > Probably 3 thread dumps will be enough. > > Thanks, > > Jun > > On Wed, Oct 15, 2014 at 11:26 AM,

[jira] [Comment Edited] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173344#comment-14173344 ] Bhavesh Mistry edited comment on KAFKA-1710 at 10/16/14 4:36 AM: ---

[jira] [Commented] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173344#comment-14173344 ] Bhavesh Mistry commented on KAFKA-1710: --- I am not able to attached yourkit profiler

[jira] [Updated] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhavesh Mistry updated KAFKA-1710: -- Attachment: th15.dump th14.dump th13.dump th12.du

[jira] [Updated] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhavesh Mistry updated KAFKA-1710: -- Attachment: Screen Shot 2014-10-15 at 9.14.15 PM.png Your Kit Monitor Screen shot: > [New Java

[jira] [Commented] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173332#comment-14173332 ] Bhavesh Mistry commented on KAFKA-1710: --- MORE OutPut: {code} Frozen threads found (

[jira] [Commented] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173330#comment-14173330 ] Bhavesh Mistry commented on KAFKA-1710: --- Here is out put of Yourkit: {code} Frozen

[jira] [Updated] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhavesh Mistry updated KAFKA-1710: -- Attachment: Screen Shot 2014-10-15 at 9.09.06 PM.png Screen Shot 2014-10-13 at 10

[jira] [Updated] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhavesh Mistry updated KAFKA-1710: -- Attachment: TestNetworkDownProducer.java Java Test Program to Reproduce this issue. > [New Java

[jira] [Created] (KAFKA-1709) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
Bhavesh Mistry created KAFKA-1709: - Summary: [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition Key: KAFKA-1709 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (KAFKA-1710) [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry (JIRA)
Bhavesh Mistry created KAFKA-1710: - Summary: [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition Key: KAFKA-1710 URL: https://issues.apache.org/jira/browse/

Re: [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Jun Rao
Probably 3 thread dumps will be enough. Thanks, Jun On Wed, Oct 15, 2014 at 11:26 AM, Bhavesh Mistry wrote: > HI Jun, > > I will file a Jira Bug for this and I will attach YourKit Profile Snapshot > and screen short. Do you want me take Thread dump each time second ? > Because the threads are

[jira] [Updated] (KAFKA-1583) Kafka API Refactoring

2014-10-15 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1583: -- Reviewer: Joel Koshy (was: Jun Rao) > Kafka API Refactoring > - > >

[jira] [Commented] (KAFKA-1583) Kafka API Refactoring

2014-10-15 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173215#comment-14173215 ] Joel Koshy commented on KAFKA-1583: --- Yes please. I will be able to do this on Friday. >

[jira] [Commented] (KAFKA-1583) Kafka API Refactoring

2014-10-15 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173210#comment-14173210 ] Jun Rao commented on KAFKA-1583: Just reviewed it. Joel, Do you want to take another loo

Re: Review Request 24676: Rebase KAFKA-1583

2014-10-15 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24676/#review56843 --- Thanks for the patch. Looks good to me. I only have some minor comme

Build failed in Jenkins: Kafka-trunk #304

2014-10-15 Thread Apache Jenkins Server
See Changes: [neha.narkhede] KAFKA-1637 SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group; reviewed by Neha Narkhede and Joel Koshy -- [...

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-15 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173157#comment-14173157 ] Jun Rao commented on KAFKA-1481: Thanks for the patch. The IDEA one applies successfully f

[DISCUSS] Release 0.8.2-beta before 0.8.2?

2014-10-15 Thread Neha Narkhede
Hi, We have accumulated an impressive list of pretty major features in 0.8.2 - Delete topic Automated leader rebalancing Controlled shutdown Offset management Parallel recovery min.isr and clean leader election In the past, what has worked for major feature releases is a beta release prior to a f

Re: Review Request 26710: Patch for KAFKA-1637

2014-10-15 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26710/#review56827 --- Ship it! Ship It! - Joel Koshy On Oct. 15, 2014, 9:47 p.m., Ewen

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1637: - Attachment: KAFKA-1637_2014-10-15_14:47:21.patch > SimpleConsumer.fetchOffset retu

[jira] [Commented] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14173018#comment-14173018 ] Ewen Cheslack-Postava commented on KAFKA-1637: -- Updated reviewboard https://r

Re: Review Request 26710: Patch for KAFKA-1637

2014-10-15 Thread Ewen Cheslack-Postava
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26710/ --- (Updated Oct. 15, 2014, 9:47 p.m.) Review request for kafka. Bugs: KAFKA-1637

[jira] [Commented] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

2014-10-15 Thread Glen Mazza (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172987#comment-14172987 ] Glen Mazza commented on KAFKA-1492: --- This seems more appropriate for the Kafka user mail

[jira] [Commented] (KAFKA-1506) Cancel "kafka-reassign-partitions" Job

2014-10-15 Thread Glen Mazza (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172977#comment-14172977 ] Glen Mazza commented on KAFKA-1506: --- As Guozhang noted, the "taking forever" may have be

[jira] [Commented] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172968#comment-14172968 ] Neha Narkhede commented on KAFKA-1637: -- [~ewencp] Your latest patch looks good. Once

[jira] [Commented] (KAFKA-1514) Update Kafka trunk version number

2014-10-15 Thread Glen Mazza (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172942#comment-14172942 ] Glen Mazza commented on KAFKA-1514: --- Trunk is presently 0.8.3-SNAPSHOT: https://git-wip

Re: [DISCUSSION] Message Metadata

2014-10-15 Thread Todd Palino
Let me add my view on #2 in less delicate terms than Guozhang did :) When you¹re trying to run Kafka as a service, having to care about the format of the message sucks. I have plenty of users who are just fine using the Avro standard and play nice. Then I have a bunch of users who don¹t want to us

Re: Review Request 26710: Patch for KAFKA-1637

2014-10-15 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26710/#review56802 --- Ship it! Minor naming comment which we can take care of on check-in

Re: Review Request 26663: Patch for KAFKA-979

2014-10-15 Thread Neha Narkhede
> On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Thinking about this a bit more: do you think it would be safer to > > interpret jitter as an additive

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

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1108: - Assignee: Ewen Cheslack-Postava Status: Patch Available (was: Open) > when

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

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172775#comment-14172775 ] Ewen Cheslack-Postava commented on KAFKA-1108: -- Created reviewboard https://r

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

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1108: - Attachment: KAFKA-1108.patch > when controlled shutdown attempt fails, the reason

Review Request 26770: Patch for KAFKA-1108

2014-10-15 Thread Ewen Cheslack-Postava
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26770/ --- Review request for kafka. Bugs: KAFKA-1108 https://issues.apache.org/jira/b

Re: [New Java Producer Potential Deadlock] Producer Deadlock when all messages is being sent to single partition

2014-10-15 Thread Bhavesh Mistry
HI Jun, I will file a Jira Bug for this and I will attach YourKit Profile Snapshot and screen short. Do you want me take Thread dump each time second ? Because the threads are blocked on SYNC code block like you mentioned and the YourKit Profile snapshot will contain Thread dump. Thanks, Bhaves

Re: Review Request 26663: Patch for KAFKA-979

2014-10-15 Thread Ewen Cheslack-Postava
> On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Thinking about this a bit more: do you think it would be safer to > > interpret jitter as an additive

Re: [DISCUSSION] Message Metadata

2014-10-15 Thread Guozhang Wang
Thanks Joe, I think we now have a few open questions to discuss around this topic: 1. Shall we make core Kafka properties as first class fields in message header or put them as tags? The pros of the first approach is more compacted format and hence less message header overhead; the cons are that

[jira] [Updated] (KAFKA-1707) ConsumerOffsetChecker shows none partitions assigned

2014-10-15 Thread Hari (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hari updated KAFKA-1707: Description: bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker shows some partitions having "none" consumers

[jira] [Created] (KAFKA-1708) Consumers intermittently stop consuming till restart

2014-10-15 Thread Hari (JIRA)
Hari created KAFKA-1708: --- Summary: Consumers intermittently stop consuming till restart Key: KAFKA-1708 URL: https://issues.apache.org/jira/browse/KAFKA-1708 Project: Kafka Issue Type: Bug Co

Re: Review Request 26373: Patch for KAFKA-1647

2014-10-15 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26373/#review56736 --- Ship it! Ship It! - Guozhang Wang On Oct. 13, 2014, 11:38 p.m.,

[jira] [Created] (KAFKA-1707) ConsumerOffsetChecker shows none partitions assigned

2014-10-15 Thread Hari (JIRA)
Hari created KAFKA-1707: --- Summary: ConsumerOffsetChecker shows none partitions assigned Key: KAFKA-1707 URL: https://issues.apache.org/jira/browse/KAFKA-1707 Project: Kafka Issue Type: Bug Co

Re: Review Request 26663: Patch for KAFKA-979

2014-10-15 Thread Joel Koshy
> On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Thinking about this a bit more: do you think it would be safer to > > interpret jitter as an additive

Re: Review Request 26663: Patch for KAFKA-979

2014-10-15 Thread Neha Narkhede
> On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Thinking about this a bit more: do you think it would be safer to > > interpret jitter as an additive

[jira] [Commented] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172543#comment-14172543 ] Jiangjie Qin commented on KAFKA-1706: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 26663: Patch for KAFKA-979

2014-10-15 Thread Ewen Cheslack-Postava
> On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Thinking about this a bit more: do you think it would be safer to > > interpret jitter as an additive

[jira] [Updated] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1706: Attachment: KAFKA-1706_2014-10-15_09:28:01.patch > Adding a byte bounded blocking queue to util. > -

Re: Review Request 26755: Patch for KAFKA-1706

2014-10-15 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26755/ --- (Updated Oct. 15, 2014, 4:28 p.m.) Review request for kafka. Bugs: KAFKA-1706

[jira] [Updated] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1706: Attachment: KAFKA-1706_2014-10-15_09:26:26.patch > Adding a byte bounded blocking queue to util. > -

[jira] [Commented] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172540#comment-14172540 ] Jiangjie Qin commented on KAFKA-1706: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 26755: Patch for KAFKA-1706

2014-10-15 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26755/ --- (Updated Oct. 15, 2014, 4:26 p.m.) Review request for kafka. Bugs: KAFKA-1706

[jira] [Updated] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1706: Status: Patch Available (was: Open) > Adding a byte bounded blocking queue to util. > -

[jira] [Updated] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1706: Attachment: KAFKA-1706.patch > Adding a byte bounded blocking queue to util. > -

[jira] [Commented] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172533#comment-14172533 ] Jiangjie Qin commented on KAFKA-1706: - Created reviewboard https://reviews.apache.org/

Review Request 26755: Patch for KAFKA-1706

2014-10-15 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26755/ --- Review request for kafka. Bugs: KAFKA-1706 https://issues.apache.org/jira/b

[jira] [Created] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-15 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created KAFKA-1706: --- Summary: Adding a byte bounded blocking queue to util. Key: KAFKA-1706 URL: https://issues.apache.org/jira/browse/KAFKA-1706 Project: Kafka Issue Type: Improve

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1637: - Status: Patch Available (was: Reopened) > SimpleConsumer.fetchOffset returns wron

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1637: - Attachment: KAFKA-1637_2014-10-15_09:08:12.patch > SimpleConsumer.fetchOffset retu

[jira] [Commented] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172513#comment-14172513 ] Ewen Cheslack-Postava commented on KAFKA-1637: -- Updated reviewboard https://r

Re: Review Request 26710: Patch for KAFKA-1637

2014-10-15 Thread Ewen Cheslack-Postava
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26710/ --- (Updated Oct. 15, 2014, 4:08 p.m.) Review request for kafka. Bugs: KAFKA-1637

Review request - Producer managed offsets

2014-10-15 Thread Ahmed khan
We have a requirement where in only one producer should be writing to a partition at once.The producer will be managing it's own offsets, what it does is at the time of startup gets latest offsets from Kafka and while producing the messages it assigns this offsets to the message.For this we had

[jira] [Commented] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

2014-10-15 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172372#comment-14172372 ] Neha Narkhede commented on KAFKA-1637: -- Wups. Didn't mean to push the patch for this

Re: Review Request 26710: Patch for KAFKA-1637

2014-10-15 Thread Neha Narkhede
> On Oct. 15, 2014, 5:22 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/server/KafkaApis.scala, line 510 > > > > > > There is an issue here. The replica manager only contains information > > about partitions th

Re: Review Request 26710: Patch for KAFKA-1637

2014-10-15 Thread Neha Narkhede
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26710/#review56699 --- core/src/main/scala/kafka/server/KafkaApis.scala

[jira] [Comment Edited] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-15 Thread Vladimir Tretyakov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172118#comment-14172118 ] Vladimir Tretyakov edited comment on KAFKA-1481 at 10/15/14 8:01 AM: ---

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-15 Thread Vladimir Tretyakov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14172118#comment-14172118 ] Vladimir Tretyakov commented on KAFKA-1481: --- Added 2 patches (created with git d

[jira] [Updated] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-15 Thread Vladimir Tretyakov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladimir Tretyakov updated KAFKA-1481: -- Attachment: KAFKA-1481_2014-10-15_10-23-35.patch KAFKA-1481_IDEA_IDE_2014