[jira] [Commented] (KAFKA-826) Make Kafka 0.8 depend on metrics 2.2.0 instead of 3.x

[ https://issues.apache.org/jira/browse/KAFKA-826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13622062#comment-13622062 ] Maxime Brugidou commented on KAFKA-826: --- Yes there has been some work and it breaks w

[jira] [Comment Edited] (KAFKA-826) Make Kafka 0.8 depend on metrics 2.2.0 instead of 3.x

[ https://issues.apache.org/jira/browse/KAFKA-826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13622062#comment-13622062 ] Maxime Brugidou edited comment on KAFKA-826 at 4/4/13 11:48 AM: -

[jira] [Created] (KAFKA-845) Re-implement shallow iteration on 0.8.1

Maxime Brugidou created KAFKA-845: - Summary: Re-implement shallow iteration on 0.8.1 Key: KAFKA-845 URL: https://issues.apache.org/jira/browse/KAFKA-845 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-743) PreferredReplicaLeaderElectionCommand has command line error

[ https://issues.apache.org/jira/browse/KAFKA-743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13566574#comment-13566574 ] Maxime Brugidou commented on KAFKA-743: --- Same thing for CheckReassignmentStatus and R

[jira] [Created] (KAFKA-732) MirrorMaker with shallow.iterator.enable=true produces unreadble messages

Maxime Brugidou created KAFKA-732: - Summary: MirrorMaker with shallow.iterator.enable=true produces unreadble messages Key: KAFKA-732 URL: https://issues.apache.org/jira/browse/KAFKA-732 Project: Kafk

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13560520#comment-13560520 ] Maxime Brugidou commented on KAFKA-139: --- I checked out 0.8 this morning and this brea

[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Attachment: KAFKA-693-v3.patch Added v3 with your remarks > Consumer rebalance

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13554852#comment-13554852 ] Maxime Brugidou commented on KAFKA-693: --- 10. Created PartitionTopicInfo.InvalidOffset

[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Attachment: KAFKA-693-v2.patch > Consumer rebalance fails if no leader available for a parti

[jira] [Commented] (KAFKA-347) change number of partitions of a topic online

[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13554458#comment-13554458 ] Maxime Brugidou commented on KAFKA-347: --- Agreed. Except you also have to think about

[jira] [Commented] (KAFKA-347) change number of partitions of a topic online

[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13553873#comment-13553873 ] Maxime Brugidou commented on KAFKA-347: --- It's sort of out of scope but I think that u

[jira] [Resolved] (KAFKA-155) Support graceful Decommissioning of Broker

[ https://issues.apache.org/jira/browse/KAFKA-155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou resolved KAFKA-155. --- Resolution: Fixed Fix Version/s: 0.8 > Support graceful Decommissioning of Broker >

[jira] [Commented] (KAFKA-155) Support graceful Decommissioning of Broker

[ https://issues.apache.org/jira/browse/KAFKA-155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13553867#comment-13553867 ] Maxime Brugidou commented on KAFKA-155: --- I think this is done in 0.8 branch with the

[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Assignee: Maxime Brugidou > Consumer rebalance fails if no leader available for a partition

[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Status: Patch Available (was: Open) > Consumer rebalance fails if no leader available for a

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13553751#comment-13553751 ] Maxime Brugidou commented on KAFKA-693: --- Here is a patch: 1. AbstractFetchThread.add

[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Attachment: KAFKA-693.patch > Consumer rebalance fails if no leader available for a partitio

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13552951#comment-13552951 ] Maxime Brugidou commented on KAFKA-693: --- Looks good, It should work but I still have

[jira] [Created] (KAFKA-701) ConsoleProducer does not exit correctly and fix some config properties following KAFKA-648

Maxime Brugidou created KAFKA-701: - Summary: ConsoleProducer does not exit correctly and fix some config properties following KAFKA-648 Key: KAFKA-701 URL: https://issues.apache.org/jira/browse/KAFKA-701

[jira] [Updated] (KAFKA-701) ConsoleProducer does not exit correctly and fix some config properties following KAFKA-648

[ https://issues.apache.org/jira/browse/KAFKA-701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-701: -- Status: Patch Available (was: Open) > ConsoleProducer does not exit correctly and fix some

[jira] [Updated] (KAFKA-701) ConsoleProducer does not exit correctly and fix some config properties following KAFKA-648

[ https://issues.apache.org/jira/browse/KAFKA-701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-701: -- Attachment: KAFKA-701.patch > ConsoleProducer does not exit correctly and fix some config pr

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13552781#comment-13552781 ] Maxime Brugidou commented on KAFKA-693: --- I looked up the code in details and I am stu

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13552759#comment-13552759 ] Maxime Brugidou commented on KAFKA-691: --- So I wait for your feedback first, but I gue

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13551978#comment-13551978 ] Maxime Brugidou commented on KAFKA-691: --- Should i make another patch? I'll try on Mon

[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Attachment: mirror_debug.log mirror.log > Consumer rebalance fails if no lea

[jira] [Created] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

Maxime Brugidou created KAFKA-693: - Summary: Consumer rebalance fails if no leader available for a partition and stops all fetchers Key: KAFKA-693 URL: https://issues.apache.org/jira/browse/KAFKA-693

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13550338#comment-13550338 ] Maxime Brugidou commented on KAFKA-691: --- Thanks for committing the patch. 3.1 Are yo

[jira] [Updated] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-691: -- Attachment: KAFKA-691-v2.patch Thanks for your feedback, I updated it (v2) according to your not

[jira] [Updated] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-691: -- Attachment: KAFKA-691-v1.patch Here is a first draft (v1) patch. 1. Added the consumer property

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13549105#comment-13549105 ] Maxime Brugidou commented on KAFKA-691: --- I agree with Jun solution, this would solve

[jira] [Commented] (KAFKA-691) Fault tolerance broken with replication factor 1

[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13548667#comment-13548667 ] Maxime Brugidou commented on KAFKA-691: --- I think the work-around is not really accept

[jira] [Commented] (KAFKA-634) ConsoleProducer compresses messages and ignores the --compress flag

[ https://issues.apache.org/jira/browse/KAFKA-634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13548441#comment-13548441 ] Maxime Brugidou commented on KAFKA-634: --- KAFKA-506 fixed this (commit f64fd3dcbaace1d

[jira] [Resolved] (KAFKA-634) ConsoleProducer compresses messages and ignores the --compress flag

[ https://issues.apache.org/jira/browse/KAFKA-634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou resolved KAFKA-634. --- Resolution: Fixed Fix Version/s: 0.8 > ConsoleProducer compresses messages and igno

[jira] [Commented] (KAFKA-690) TopicMetadataRequest throws exception when no topics are specified

[ https://issues.apache.org/jira/browse/KAFKA-690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13548436#comment-13548436 ] Maxime Brugidou commented on KAFKA-690: --- this would resolve KAFKA-653

[jira] [Commented] (KAFKA-281) support multiple root log directories

[ https://issues.apache.org/jira/browse/KAFKA-281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13546858#comment-13546858 ] Maxime Brugidou commented on KAFKA-281: --- I guess this was done on 0.8 as part of KAFK

[jira] [Updated] (KAFKA-684) ConsoleProducer does not have the queue-size option

[ https://issues.apache.org/jira/browse/KAFKA-684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-684: -- Attachment: KAFKA-684-3.patch While I'm at it, I added this small feature: Exit at end of input

[jira] [Updated] (KAFKA-684) ConsoleProducer does not have the queue-size option

[ https://issues.apache.org/jira/browse/KAFKA-684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-684: -- Attachment: KAFKA-684-2.patch I added: queue.enqueueTimeout.ms producer.request.required.acks p

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Attachment: KAFKA-685-2.patch New patch, updated the regex to ignore JMX port >

[jira] [Updated] (KAFKA-685) ConsumerOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsumerOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-685) ConsumerOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Summary: ConsumerOffsetChecker does not work with 0.8 (was: ConsoleOffsetChecker does not work

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Status: Patch Available (was: Open) > ConsoleOffsetChecker does not work with 0.8 > ---

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Attachment: KAFKA-685.patch > ConsoleOffsetChecker does not work with 0.8 >

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Created] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

Maxime Brugidou created KAFKA-685: - Summary: ConsoleOffsetChecker does not work with 0.8 Key: KAFKA-685 URL: https://issues.apache.org/jira/browse/KAFKA-685 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8

[ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: -- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful

[jira] [Updated] (KAFKA-684) ConsoleProducer does not have the queue-size option

[ https://issues.apache.org/jira/browse/KAFKA-684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-684: -- Attachment: KAFKA-684.patch > ConsoleProducer does not have the queue-size option >

[jira] [Created] (KAFKA-684) ConsoleProducer does not have the queue-size option

Maxime Brugidou created KAFKA-684: - Summary: ConsoleProducer does not have the queue-size option Key: KAFKA-684 URL: https://issues.apache.org/jira/browse/KAFKA-684 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-684) ConsoleProducer does not have the queue-size option

[ https://issues.apache.org/jira/browse/KAFKA-684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-684: -- Fix Version/s: 0.8 Affects Version/s: 0.8 Status: Patch Available (was: O

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

[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-133: -- Attachment: KAFKA-133.patch Taking Otis notes into account, Here is the simplest patch I could m