[
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 br
[
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:4
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
[
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
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
[
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
[
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 rebala
[
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. Cre
[
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 fo
[
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 a
[
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 t
[
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 Bro
[
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
[
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 partit
[
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
[
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
[
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 fo
[
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
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
[
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 s
[
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 con
[
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
[
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, b
[
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'
[
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
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
[
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
[
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
[
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
[
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 s
[
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 re
Thanks for your response. I think the work-around is not really acceptable
for me since it will consume 3x the resources (because replication of 3 is
the minimum acceptable) and it will still make the cluster less available
anyway (unless i have only 3 brokers).
The thing is that 0.7 was making th
[
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 (co
[
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
[
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
[
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 par
[
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 e
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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 opt
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
[
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
[
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
55 matches
Mail list logo
