[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2146:
---
Attachment: (was: KAFKA-2146.2)
> adding partition did not find the correct startIndex
>
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2146:
---
Attachment: KAFKA-2146.2.patch
> adding partition did not find the correct startIndex
> -
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2146:
---
Attachment: KAFKA-2146.2
updated patch.
> adding partition did not find the correct startIndex
> ---
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14710474#comment-14710474
]
chenshangan commented on KAFKA-2106:
There are two things here:
1) about 3 replica res
[
https://issues.apache.org/jira/browse/KAFKA-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699875#comment-14699875
]
chenshangan commented on KAFKA-1792:
you guys can take a look at https://issues.apache
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Attachment: KAFKA-2106.3
implement a global balance among the cluster, which will destroy the original
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565723#comment-14565723
]
chenshangan commented on KAFKA-188:
---
[~jkreps]
"I recommend we instead leave this as it
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564610#comment-14564610
]
chenshangan edited comment on KAFKA-188 at 5/29/15 3:49 PM:
[~j
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564610#comment-14564610
]
chenshangan commented on KAFKA-188:
---
@Jay Kreps I think we could provide a alternative,
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539476#comment-14539476
]
chenshangan commented on KAFKA-2146:
[~guozhang] It's ok.
For #2 I totally agree, it'
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513653#comment-14513653
]
chenshangan commented on KAFKA-2106:
if new assignment start from the original startin
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513575#comment-14513575
]
chenshangan edited comment on KAFKA-2106 at 4/27/15 7:20 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2146:
---
Attachment: KAFKA-2146.patch
> adding partition did not find the correct startIndex
> ---
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2146:
---
Status: Patch Available (was: Open)
use partition 0 as head partition;
find the index of first replic
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Attachment: KAFKA-2106.patch.2
check reassignment status, Thread.sleep according to the status rather
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14510903#comment-14510903
]
chenshangan commented on KAFKA-2146:
I'd like to provide a patch soon.
> adding parti
chenshangan created KAFKA-2146:
--
Summary: adding partition did not find the correct startIndex
Key: KAFKA-2146
URL: https://issues.apache.org/jira/browse/KAFKA-2146
Project: Kafka
Issue Type: B
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Attachment: KAFKA-2106.patch
Implement basic rehash assignment algorithm
> Partition balance tool bet
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Reviewer: Jun Rao
Status: Patch Available (was: Open)
> Partition balance tool between borkers
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14510614#comment-14510614
]
chenshangan commented on KAFKA-2106:
When adding new brokers to the cluster, existing
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Comment: was deleted
(was: Topics in the cluster can be divided into two categories:
1. nPartitions >
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14484948#comment-14484948
]
chenshangan commented on KAFKA-2106:
Topics in the cluster can be divided into two cat
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Description: The default partition assignment algorithm can work well in a
static kafka cluster(number
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Description: The default partition assignment algorithm can work well in a
static kafka cluster(number
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Component/s: admin
> Partition balance tool between borkers
> --
>
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Affects Version/s: 0.8.3
> Partition balance tool between borkers
> --
chenshangan created KAFKA-2106:
--
Summary: Partition balance tool between borkers
Key: KAFKA-2106
URL: https://issues.apache.org/jira/browse/KAFKA-2106
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14201821#comment-14201821
]
chenshangan edited comment on KAFKA-188 at 11/7/14 9:16 AM:
ass
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14201821#comment-14201821
]
chenshangan commented on KAFKA-188:
---
assign a new partition to the dir with the fewest pa
[
https://issues.apache.org/jira/browse/KAFKA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenshangan resolved KAFKA-1640.
Resolution: Not a Problem
> consumer will fail if encounter special offset
> ---
[
https://issues.apache.org/jira/browse/KAFKA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14139928#comment-14139928
]
chenshangan commented on KAFKA-1640:
[~guozhang] thanks for you suggestion, it's beca
[
https://issues.apache.org/jira/browse/KAFKA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14138733#comment-14138733
]
chenshangan commented on KAFKA-1640:
The following is about the test:
offset info wit
chenshangan created KAFKA-1640:
--
Summary: consumer will fail if encounter special offset
Key: KAFKA-1640
URL: https://issues.apache.org/jira/browse/KAFKA-1640
Project: Kafka
Issue Type: Bug
33 matches
Mail list logo