[
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-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: (was: KAFKA-2146.2)
> adding partition did not find the correct startIndex
>
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710474#comment-14710474
]
chenshangan commented on KAFKA-2106:
There are two things here:
1) about 3 replica
[
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
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14564610#comment-14564610
]
chenshangan commented on KAFKA-188:
---
@Jay Kreps I think we could provide a alternative,
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14564610#comment-14564610
]
chenshangan edited comment on KAFKA-188 at 5/29/15 3:49 PM:
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14565723#comment-14565723
]
chenshangan commented on KAFKA-188:
---
[~jkreps]
I recommend we instead leave this as it
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539476#comment-14539476
]
chenshangan commented on KAFKA-2146:
[~guozhang] It's ok.
For #2 I totally agree,
[
https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513575#comment-14513575
]
chenshangan edited comment on KAFKA-2106 at 4/27/15 7:20 AM:
-
[
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: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-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513653#comment-14513653
]
chenshangan commented on KAFKA-2106:
if new assignment start from the original
[
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
[
https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14510903#comment-14510903
]
chenshangan commented on KAFKA-2146:
I'd like to provide a patch soon.
adding
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:
[
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-tabpanelfocusedCommentId=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:
---
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:all-tabpanel
]
chenshangan updated KAFKA-2106:
---
Attachment: KAFKA-2106.patch
Implement basic rehash assignment algorithm
Partition balance tool
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-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
[
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:
---
Description: The default partition assignment algorithm can work well in a
static kafka
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14201821#comment-14201821
]
chenshangan commented on KAFKA-188:
---
assign a new partition to the dir with the fewest
[
https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14201821#comment-14201821
]
chenshangan edited comment on KAFKA-188 at 11/7/14 9:16 AM:
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
[
https://issues.apache.org/jira/browse/KAFKA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14138733#comment-14138733
]
chenshangan commented on KAFKA-1640:
The following is about the test:
offset info
[
https://issues.apache.org/jira/browse/KAFKA-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14139928#comment-14139928
]
chenshangan commented on KAFKA-1640:
[~guozhang] thanks for you suggestion, it's
[
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
30 matches
Mail list logo
