[jira] [Commented] (KAFKA-521) Refactor Log subsystem

2012-11-27 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13505183#comment-13505183 ] Neha Narkhede commented on KAFKA-521: - Pretty good cleanup and great usage of

Re: Kafka 0.8 trial version

2012-11-27 Thread Neha Narkhede
Following are the major changes - 1. Logical offsets The design document is here: https://cwiki.apache.org/confluence/display/KAFKA/Keyed+Messages+Proposal The JIRA has a number of technical details regarding the logical offsets: https://issues.apache.org/jira/browse/KAFKA-506 2. Replicatio

[jira] [Resolved] (KAFKA-344) migration tool from 0.7 to 0.8

2012-11-22 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-344. - Resolution: Fixed Yes, this is done now > migration tool from 0.7 to

[jira] [Closed] (KAFKA-344) migration tool from 0.7 to 0.8

2012-11-22 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-344. --- > migration tool from 0.7 to 0.8 > -- > > Ke

[jira] [Commented] (KAFKA-622) Create mbeans per client

2012-11-22 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13502889#comment-13502889 ] Neha Narkhede commented on KAFKA-622: - Thanks for incorporating suggestions in

[jira] [Updated] (KAFKA-133) Publish kafka jar to a public maven repository

2012-11-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-133: Fix Version/s: 0.8 > Publish kafka jar to a public maven reposit

[jira] [Updated] (KAFKA-630) Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException

2012-11-20 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-630: Affects Version/s: 0.8 > Auto create topic doesn't reflect the new topic an

[jira] [Created] (KAFKA-630) Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException

2012-11-20 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-630: --- Summary: Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException Key: KAFKA-630 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Commented] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests

2012-11-19 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13500427#comment-13500427 ] Neha Narkhede commented on KAFKA-626: - nnarkhed-ld:apache-kafka-0.8 nnarkhed$

[jira] [Created] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests

2012-11-19 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-626: --- Summary: Produce requests dropped due to socket timeouts on get metadata requests Key: KAFKA-626 URL: https://issues.apache.org/jira/browse/KAFKA-626 Project: Kafka

[jira] [Commented] (KAFKA-612) move shutting down of fetcher thread out of critical path

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499956#comment-13499956 ] Neha Narkhede commented on KAFKA-612: - Minor nitpick before you checkin v2 - Pl

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499949#comment-13499949 ] Neha Narkhede commented on KAFKA-513: - Swapnil, I think this JIRA is missing

[jira] [Resolved] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-532. - Resolution: Fixed 50. Agree that the request/response formats must be consistent. Let's

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499940#comment-13499940 ] Neha Narkhede commented on KAFKA-133: - * How come this is not Fix Version 0.8? Sh

[jira] [Updated] (KAFKA-133) Publish kafka jar to a public maven repository

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-133: Affects Version/s: 0.8 > Publish kafka jar to a public maven reposit

[jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499938#comment-13499938 ] Neha Narkhede commented on KAFKA-544: - Minor comment - The API docs are broke

[jira] [Closed] (KAFKA-625) Improve MessageAndMetadata to expose the partition

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-625. --- > Improve MessageAndMetadata to expose the partit

[jira] [Resolved] (KAFKA-625) Improve MessageAndMetadata to expose the partition

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-625. - Resolution: Duplicate Fix Version/s: 0.8 Fixed as part of KAFKA-544

[jira] [Updated] (KAFKA-616) Implement acks=0

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-616: Affects Version/s: 0.8 > Implement acks=0 > > > Ke

[jira] [Created] (KAFKA-625) Improve MessageAndMetadata to expose the partition

2012-11-18 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-625: --- Summary: Improve MessageAndMetadata to expose the partition Key: KAFKA-625 URL: https://issues.apache.org/jira/browse/KAFKA-625 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499873#comment-13499873 ] Neha Narkhede commented on KAFKA-532: - Thanks for reviewing patch v5 quickly !

[jira] [Commented] (KAFKA-622) Create mbeans per client

2012-11-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499861#comment-13499861 ] Neha Narkhede commented on KAFKA-622: - 1. AbstractFetcherThread 1.1 Maybe the clie

[jira] [Commented] (KAFKA-612) move shutting down of fetcher thread out of critical path

2012-11-17 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499572#comment-13499572 ] Neha Narkhede commented on KAFKA-612: - Overall, the fix looks good, here are a

[jira] [Comment Edited] (KAFKA-612) move shutting down of fetcher thread out of critical path

2012-11-17 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499572#comment-13499572 ] Neha Narkhede edited comment on KAFKA-612 at 11/18/12 1:0

[jira] [Commented] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker

2012-11-17 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499561#comment-13499561 ] Neha Narkhede commented on KAFKA-620: - I would check if the zookeeper connec

[jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-11-17 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-532: Attachment: kafka-532-v5.patch ew more changes in this patch - 1. Changed leader and isr request

[jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem

2012-11-15 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13498388#comment-13498388 ] Neha Narkhede commented on KAFKA-545: - +1.. its great to have this test checke

[jira] [Commented] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK

2012-11-14 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13497642#comment-13497642 ] Neha Narkhede commented on KAFKA-574: - +1. Looks good and tests

[jira] [Closed] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK

2012-11-14 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-574. --- Thanks for the patch, Prashanth! > KafkaController unnecessarily reads leaderAndIsr i

[jira] [Resolved] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK

2012-11-14 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-574. - Resolution: Fixed Checked it in since it blocks work on KAFKA-532

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

2012-11-13 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496860#comment-13496860 ] Neha Narkhede commented on KAFKA-133: - >> So is the blocker for this issu

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

2012-11-13 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13496321#comment-13496321 ] Neha Narkhede commented on KAFKA-133: - >> Custom zkclient jar... may

[jira] [Commented] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK

2012-11-06 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13491657#comment-13491657 ] Neha Narkhede commented on KAFKA-574: - I ran system tests but they failed and all

[jira] [Resolved] (KAFKA-593) Empty log index file created when it shouldn't be empty

2012-11-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-593. - Resolution: Fixed +1 on v5. Committed this patch > Empty log index file crea

[jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index

2012-11-04 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13490305#comment-13490305 ] Neha Narkhede commented on KAFKA-577: - Sorry for coming to this a little late. P

[jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to

2012-11-04 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13490298#comment-13490298 ] Neha Narkhede commented on KAFKA-596: - Good catch, Jun ! +1 o

[jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-11-02 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-532: Attachment: kafka-532-v4.patch 31. Partition.updateIsr(): I am thinking about what controllerEpoch

Re: Maintainer system?

2012-11-02 Thread Neha Narkhede
+1 on this, I like the idea of having a primary/secondary owner system for each component. Thanks, Neha On Thu, Nov 1, 2012 at 10:15 PM, Jun Rao wrote: > I think that's a good idea. It will be good to have at least 2 maintainers > per component. > > I'd encourage more people to review patches. T

[jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-11-01 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13489181#comment-13489181 ] Neha Narkhede commented on KAFKA-532: - >> 34. KafkaController: There see

[jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem

2012-11-01 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13488843#comment-13488843 ] Neha Narkhede commented on KAFKA-545: - Makes sense, are the reads in your test u

[jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-10-31 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-532: Attachment: kafka-532-v3.patch >> So we don't need to rewrite leaderAndIsr during

[jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-10-31 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-532: Status: In Progress (was: Patch Available) > Multiple controllers can co-exist during s

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

2012-10-31 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13488162#comment-13488162 ] Neha Narkhede commented on KAFKA-513: - Prashanth, how is the work on this going

[jira] [Updated] (KAFKA-595) Producer side compression is unnecessary

2012-10-31 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-595: Issue Type: Improvement (was: Bug) > Producer side compression is unnecess

[jira] [Commented] (KAFKA-595) Producer side compression is unnecessary

2012-10-31 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13487915#comment-13487915 ] Neha Narkhede commented on KAFKA-595: - >> I would recommend we ins

[jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly

2012-10-30 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13487164#comment-13487164 ] Neha Narkhede commented on KAFKA-588: - +1 on v2, good catch ! >

[jira] [Commented] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance

2012-10-30 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13487067#comment-13487067 ] Neha Narkhede commented on KAFKA-594: - Looks good, +1 > Update

[jira] [Created] (KAFKA-595) Producer side compression is unnecessary

2012-10-30 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-595: --- Summary: Producer side compression is unnecessary Key: KAFKA-595 URL: https://issues.apache.org/jira/browse/KAFKA-595 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload

2012-10-26 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13485032#comment-13485032 ] Neha Narkhede commented on KAFKA-267: - Keeping the printing in ProducerPerform

[jira] [Resolved] (KAFKA-340) Implement clean shutdown in 0.8

2012-10-26 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-340. - Resolution: Fixed Patch is committed. > Implement clean shutdown in

[jira] [Closed] (KAFKA-340) Implement clean shutdown in 0.8

2012-10-26 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-340. --- > Implement clean shutdown in 0.8 > --- > >

[jira] [Commented] (KAFKA-188) Support multiple data directories

2012-10-25 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13484654#comment-13484654 ] Neha Narkhede commented on KAFKA-188: - Took a quick look at patch v4. Here are

Re: end-to-end latency in kafka 0.8

2012-10-25 Thread Neha Narkhede
Single machine performance looks great. I'm assuming this was done with replication factor = 1, right ? In reality, the only factor that can affect this number, is the time it takes for the followers to fetch the data. This is important for end-to-end latency since until the follower replicas fetc

[jira] [Created] (KAFKA-586) system test configs are broken

2012-10-25 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-586: --- Summary: system test configs are broken Key: KAFKA-586 URL: https://issues.apache.org/jira/browse/KAFKA-586 Project: Kafka Issue Type: Bug Affects

[jira] [Commented] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1

2012-10-25 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13484321#comment-13484321 ] Neha Narkhede commented on KAFKA-584: - +1, but should we get rid of the info state

[jira] [Created] (KAFKA-584) produce/fetch remote time metric not set correctly when num.acks = 1

2012-10-24 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-584: --- Summary: produce/fetch remote time metric not set correctly when num.acks = 1 Key: KAFKA-584 URL: https://issues.apache.org/jira/browse/KAFKA-584 Project: Kafka

[jira] [Comment Edited] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload

2012-10-24 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483415#comment-13483415 ] Neha Narkhede edited comment on KAFKA-267 at 10/24/12 6:0

[jira] [Commented] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload

2012-10-24 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483415#comment-13483415 ] Neha Narkhede commented on KAFKA-267: - Thanks for patch v5, we are pretty clos

[jira] [Commented] (KAFKA-579) remove connection timeout in SyncProducer

2012-10-24 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483411#comment-13483411 ] Neha Narkhede commented on KAFKA-579: - I see, missed that. Sounds

[jira] [Commented] (KAFKA-579) remove connection timeout in SyncProducer

2012-10-24 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13483391#comment-13483391 ] Neha Narkhede commented on KAFKA-579: - I guess it is still useful to have a VIP

[jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8

2012-10-23 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13482523#comment-13482523 ] Neha Narkhede commented on KAFKA-340: - Thanks for patch v2, looks good overall. Co

[jira] [Commented] (KAFKA-580) system test testcase_0122 under replication fails due to large # of data loss

2012-10-23 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13482474#comment-13482474 ] Neha Narkhede commented on KAFKA-580: - +1 > system test testca

[jira] [Resolved] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests

2012-10-22 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-541. - Resolution: Fixed Committed v4 after making the following changes to v3 - 1. Fixed a logging

[jira] [Closed] (KAFKA-541) Use metrics CSV reporter instead of jmx tool for system tests

2012-10-22 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-541. --- > Use metrics CSV reporter instead of jmx tool for system te

Re: [VOTE] Graduate Kafka from Incubator to TLP status

2012-10-18 Thread Neha Narkhede
of the Apache Kafka Project, and to have primary responsibility > for management of the projects within the scope of > responsibility of the Apache Kafka Project; and be it further > > RESOLVED, that the persons listed immediately below be and > hereby are appointed

[jira] [Commented] (KAFKA-573) System Test : Leader Failure Log Segment Checksum Mismatched When request-num-acks is 1

2012-10-18 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13479429#comment-13479429 ] Neha Narkhede commented on KAFKA-573: - +1, this one was fun to track down. Reminde

[jira] [Commented] (KAFKA-566) Add last modified time to the TopicMetadataRequest

2012-10-17 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13478336#comment-13478336 ] Neha Narkhede commented on KAFKA-566: - TopicMetadataRequest is the right class to

[jira] [Commented] (KAFKA-340) Implement clean shutdown in 0.8

2012-10-17 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13478202#comment-13478202 ] Neha Narkhede commented on KAFKA-340: - Thanks for the patch, it looks very

[jira] [Closed] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-537. --- Committed the v3 patch > expose clientId and correlationId in ConsumerCon

[jira] [Resolved] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-537. - Resolution: Fixed > expose clientId and correlationId in ConsumerCon

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

2012-10-15 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13476605#comment-13476605 ] Neha Narkhede commented on KAFKA-513: - log4j appender providing a real

[jira] [Commented] (KAFKA-188) Support multiple data directories

2012-10-15 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13476472#comment-13476472 ] Neha Narkhede commented on KAFKA-188: - +1 on maintaining one highwatermark file

Re: Erlang library for Kafka 0.7.x

2012-10-15 Thread Neha Narkhede
Looks great, thanks for sharing ! -Neha On Sat, Oct 13, 2012 at 10:34 PM, Milind Parikh wrote: > https://github.com/milindparikh/erlkafka.git > > > > erlkafka is a kafka client written in erlang. > > erlkafka provides seven core functions > > produce%% native kafka pr

[jira] [Resolved] (KAFKA-569) Cleanup kafka.utils.Utils

2012-10-13 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-569. - Resolution: Fixed > Cleanup kafka.utils.Ut

[jira] [Closed] (KAFKA-569) Cleanup kafka.utils.Utils

2012-10-13 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-569. --- > Cleanup kafka.utils.Utils > - > > Ke

[jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-43?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-43: --- Resolution: Fixed Status: Resolved (was: Patch Available) Addressed v2 review comments and

[jira] [Closed] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-43?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-43. -- > Rebalance to preferred broke with intra-cluster replication supp

[jira] [Resolved] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-548. - Resolution: Fixed Assignee: Yang Ye Committed v3 after minor formatting changes

[jira] [Closed] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-548. --- > remove partition from ProducerRequestPartitionData and > FetchResponsePartiti

[jira] [Commented] (KAFKA-569) Cleanup kafka.utils.Utils

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475445#comment-13475445 ] Neha Narkhede commented on KAFKA-569: - >> The problem with this is that

[jira] [Comment Edited] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-43?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475435#comment-13475435 ] Neha Narkhede edited comment on KAFKA-43 at 10/12/12 11:3

[jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-43?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-43: --- Attachment: kafka-43-v2.patch Thanks for the review, Jun and Joel ! Here is a follow up patch to

[jira] [Commented] (KAFKA-569) Cleanup kafka.utils.Utils

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475430#comment-13475430 ] Neha Narkhede commented on KAFKA-569: - Looks good, just one thing that I missed in

[jira] [Commented] (KAFKA-548) remove partition from ProducerRequestPartitionData and FetchResponsePartitionData

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475179#comment-13475179 ] Neha Narkhede commented on KAFKA-548: - Thanks for patch v2, here are few re

[jira] [Commented] (KAFKA-568) LogTest started failing after KAFKA-506

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475159#comment-13475159 ] Neha Narkhede commented on KAFKA-568: - >> One thing that would help a lo

[jira] [Commented] (KAFKA-567) Replication Data Loss in Mirror Maker Bouncing testcase

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475153#comment-13475153 ] Neha Narkhede commented on KAFKA-567: - +1 on KAFKA-567.patch, good c

[jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13475110#comment-13475110 ] Neha Narkhede commented on KAFKA-537: - Until you rebase, I reviewed v2 on an older

[jira] [Commented] (KAFKA-569) Cleanup kafka.utils.Utils

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474770#comment-13474770 ] Neha Narkhede commented on KAFKA-569: - Looks great, thanks for contributing

[jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474761#comment-13474761 ] Neha Narkhede commented on KAFKA-537: - v2 doesn't apply cleanly, probably d

[jira] [Closed] (KAFKA-432) allow consumer to read from followers

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-432. --- > allow consumer to read from follow

[jira] [Resolved] (KAFKA-432) allow consumer to read from followers

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-432. - Resolution: Fixed Committed v5. > allow consumer to read from follow

[jira] [Commented] (KAFKA-432) allow consumer to read from followers

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474741#comment-13474741 ] Neha Narkhede commented on KAFKA-432: - +1. v5 looks good. >

[jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474739#comment-13474739 ] Neha Narkhede commented on KAFKA-537: - Got it, thanks for the explanation, make

[jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474725#comment-13474725 ] Neha Narkhede commented on KAFKA-537: - Forgive me for asking a pretty basic ques

[jira] [Commented] (KAFKA-432) allow consumer to read from followers

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474720#comment-13474720 ] Neha Narkhede commented on KAFKA-432: - Thanks for the patch! Overall, looks pr

[jira] [Commented] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-43?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474638#comment-13474638 ] Neha Narkhede commented on KAFKA-43: In addition to the above, I realized there

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474626#comment-13474626 ] Neha Narkhede commented on KAFKA-513: - Hey Prashanth, just checking in to see how

[jira] [Created] (KAFKA-568) LogTest started failing after KAFKA-506

2012-10-11 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-568: --- Summary: LogTest started failing after KAFKA-506 Key: KAFKA-568 URL: https://issues.apache.org/jira/browse/KAFKA-568 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-510) broker needs to know the replication factor per partition

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13474608#comment-13474608 ] Neha Narkhede commented on KAFKA-510: - +1. Only 4.1 was not addressed, but I

[jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support

2012-10-11 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-43?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-43: --- Attachment: kafka-43-v1.patch Added the ability to move the leader to the preferred replica for a

  1   2   3   4   5   6   7   8   9   10   >