[jira] [Created] (KAFKA-7411) Change system to future and change back will make replication not working

2018-09-14 Thread Pengwei (JIRA)
Pengwei created KAFKA-7411: -- Summary: Change system to future and change back will make replication not working Key: KAFKA-7411 URL: https://issues.apache.org/jira/browse/KAFKA-7411 Project: Kafka

[jira] [Created] (KAFKA-5425) Kafka replication support all log segment files sync with leader

2017-06-09 Thread Pengwei (JIRA)
Pengwei created KAFKA-5425: -- Summary: Kafka replication support all log segment files sync with leader Key: KAFKA-5425 URL: https://issues.apache.org/jira/browse/KAFKA-5425 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR

2017-06-20 Thread Pengwei (JIRA)
Pengwei created KAFKA-5480: -- Summary: Partition Leader may not be elected although there is one live replica in ISR Key: KAFKA-5480 URL: https://issues.apache.org/jira/browse/KAFKA-5480 Project: Kafka

[jira] [Created] (KAFKA-5553) Delete topic failed to change from OnlineReplica to ReplicaDeletionStarted if ISR not created

2017-07-04 Thread Pengwei (JIRA)
Pengwei created KAFKA-5553: -- Summary: Delete topic failed to change from OnlineReplica to ReplicaDeletionStarted if ISR not created Key: KAFKA-5553 URL: https://issues.apache.org/jira/browse/KAFKA-5553 Proj

[jira] [Created] (KAFKA-5752) Delete topic and re-create topic immediate will delete the new topic's timeindex

2017-08-19 Thread Pengwei (JIRA)
Pengwei created KAFKA-5752: -- Summary: Delete topic and re-create topic immediate will delete the new topic's timeindex Key: KAFKA-5752 URL: https://issues.apache.org/jira/browse/KAFKA-5752 Project: Kafka

[jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown

2016-06-15 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331523#comment-15331523 ] Pengwei commented on KAFKA-1429: I can still reproduce this issue in 0.9.0.0 or 0.9.0.1,

[jira] [Updated] (KAFKA-1429) Yet another deadlock in controller shutdown

2016-06-17 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-1429: --- Attachment: kafka_0.9.0.0_controller_dead_lock.patch upload file is the patch to fix this bug, can somebody re

[jira] [Created] (KAFKA-3913) Old consumer's metrics error when using IPv6

2016-06-28 Thread Pengwei (JIRA)
Pengwei created KAFKA-3913: -- Summary: Old consumer's metrics error when using IPv6 Key: KAFKA-3913 URL: https://issues.apache.org/jira/browse/KAFKA-3913 Project: Kafka Issue Type: Bug Com

[jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown

2016-07-23 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15390887#comment-15390887 ] Pengwei commented on KAFKA-1429: hi Jun, I have open a PR for this issue. Can you review i

[jira] [Commented] (KAFKA-4229) Controller can't start after several zk expired event

2016-11-26 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15698992#comment-15698992 ] Pengwei commented on KAFKA-4229: The PR is : https://github.com/apache/kafka/pull/2175 >

[jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event

2016-11-26 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Reviewer: Guozhang Wang > Controller can't start after several zk expired event >

[jira] [Work started] (KAFKA-4229) Controller can't start after several zk expired event

2016-11-26 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4229 started by Pengwei. -- > Controller can't start after several zk expired event > ---

[jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event

2016-11-26 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Status: Patch Available (was: In Progress) PR : https://github.com/apache/kafka/pull/2175 > Controller can't

[jira] [Created] (KAFKA-4790) Kafka can't not recover after a disk full

2017-02-23 Thread Pengwei (JIRA)
Pengwei created KAFKA-4790: -- Summary: Kafka can't not recover after a disk full Key: KAFKA-4790 URL: https://issues.apache.org/jira/browse/KAFKA-4790 Project: Kafka Issue Type: Bug Affects Versi

[jira] [Commented] (KAFKA-4790) Kafka can't not recover after a disk full

2017-02-23 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15880567#comment-15880567 ] Pengwei commented on KAFKA-4790: The index max file set to 1MB log.index.size.max.bytes=10

[jira] [Created] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time

2017-03-07 Thread Pengwei (JIRA)
Pengwei created KAFKA-4862: -- Summary: Kafka client connect to a shutdown node will block for a long time Key: KAFKA-4862 URL: https://issues.apache.org/jira/browse/KAFKA-4862 Project: Kafka Issue T

[jira] [Commented] (KAFKA-4790) Kafka cannot recover after a disk full

2017-03-09 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904333#comment-15904333 ] Pengwei commented on KAFKA-4790: [~junrao] If KIP-98 can fix this issue, we can wait for t

[jira] [Comment Edited] (KAFKA-4790) Kafka cannot recover after a disk full

2017-03-10 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904333#comment-15904333 ] Pengwei edited comment on KAFKA-4790 at 3/10/17 10:54 AM: -- [~junr

[jira] [Created] (KAFKA-5014) SSL Channel not ready but tcp is established and the server is hung will not sending metadata

2017-04-05 Thread Pengwei (JIRA)
Pengwei created KAFKA-5014: -- Summary: SSL Channel not ready but tcp is established and the server is hung will not sending metadata Key: KAFKA-5014 URL: https://issues.apache.org/jira/browse/KAFKA-5014 Proje

[jira] [Updated] (KAFKA-4862) Kafka client connect to a shutdown node will block for a long time

2017-04-17 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4862: --- Status: Patch Available (was: Open) > Kafka client connect to a shutdown node will block for a long time > --

[jira] [Created] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

2017-01-05 Thread Pengwei (JIRA)
Pengwei created KAFKA-4595: -- Summary: Controller send thread can't stop when broker change listener event trigger for dead brokers Key: KAFKA-4595 URL: https://issues.apache.org/jira/browse/KAFKA-4595 Proje

[jira] [Commented] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

2017-01-05 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15801343#comment-15801343 ] Pengwei commented on KAFKA-4595: The broker change event is trigger to remove dead brokers

[jira] [Commented] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

2017-01-05 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15803812#comment-15803812 ] Pengwei commented on KAFKA-4595: Yes, you are right. > Controller send thread can't stop

[jira] [Commented] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

2017-01-05 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15803816#comment-15803816 ] Pengwei commented on KAFKA-4595: [~huxi_2b] > Controller send thread can't stop when brok

[jira] [Commented] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

2017-01-09 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811007#comment-15811007 ] Pengwei commented on KAFKA-4595: One method is to add a lock timeout method instead of blo

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

2017-01-10 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15817467#comment-15817467 ] Pengwei commented on KAFKA-3042: [~lindong] It seems I still encounter this issue after a

[jira] [Reopened] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

2017-01-10 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei reopened KAFKA-3042: > updateIsr should stop after failed several times due to zkVersion issue >

[jira] [Comment Edited] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

2017-01-10 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15817467#comment-15817467 ] Pengwei edited comment on KAFKA-3042 at 1/11/17 7:27 AM: - [~lindon

[jira] [Created] (KAFKA-3562) Null Pointer Exception Found when delete topic and Using New Producer

2016-04-15 Thread Pengwei (JIRA)
Pengwei created KAFKA-3562: -- Summary: Null Pointer Exception Found when delete topic and Using New Producer Key: KAFKA-3562 URL: https://issues.apache.org/jira/browse/KAFKA-3562 Project: Kafka Issu

[jira] [Created] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

2016-04-19 Thread Pengwei (JIRA)
Pengwei created KAFKA-3584: -- Summary: NullPointer Exception found when Delete Topic and Log delete concurrent Key: KAFKA-3584 URL: https://issues.apache.org/jira/browse/KAFKA-3584 Project: Kafka Is

[jira] [Created] (KAFKA-3585) Shutdown slow when there is only one broker which is controller

2016-04-19 Thread Pengwei (JIRA)
Pengwei created KAFKA-3585: -- Summary: Shutdown slow when there is only one broker which is controller Key: KAFKA-3585 URL: https://issues.apache.org/jira/browse/KAFKA-3585 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-3585) Shutdown slow when there is only one broker which is controller

2016-05-02 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268171#comment-15268171 ] Pengwei commented on KAFKA-3585: Is the last broker become the controller ? I can repro

[jira] [Commented] (KAFKA-3585) Shutdown slow when there is only one broker which is controller

2016-05-08 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15275880#comment-15275880 ] Pengwei commented on KAFKA-3585: do you used the kafka-server-stop.sh to shutdown? > Shut

[jira] [Issue Comment Deleted] (KAFKA-3585) Shutdown slow when there is only one broker which is controller

2016-05-08 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-3585: --- Comment: was deleted (was: do you used the kafka-server-stop.sh to shutdown?) > Shutdown slow when there is o

[jira] [Commented] (KAFKA-3585) Shutdown slow when there is only one broker which is controller

2016-05-08 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15275879#comment-15275879 ] Pengwei commented on KAFKA-3585: do you used the kafka-server-stop.sh to shutdown? > Shut

[jira] [Commented] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

2015-12-08 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15046561#comment-15046561 ] Pengwei commented on KAFKA-2903: Yes we can also add comment on it. But if in the future

[jira] [Created] (KAFKA-2995) in 0.9.0.0 Old Consumer's commitOffsets with specify partition can submit not exists topic and partition to zk

2015-12-16 Thread Pengwei (JIRA)
Pengwei created KAFKA-2995: -- Summary: in 0.9.0.0 Old Consumer's commitOffsets with specify partition can submit not exists topic and partition to zk Key: KAFKA-2995 URL: https://issues.apache.org/jira/browse/KAFKA-2995

[jira] [Created] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

2016-01-06 Thread Pengwei (JIRA)
Pengwei created KAFKA-3075: -- Summary: java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets Key: KAFKA-3075 URL: https://issues.apache.org/jira/browse/KA

[jira] [Updated] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

2016-01-06 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-3075: --- Description: When using java api's commit offset : public void commitOffsets(Map offsetsToCommit, boolean r

[jira] [Updated] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

2016-01-06 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-3075: --- Description: When using java api's commit offset : public void commitOffsets(Map offsetsToCommit, boolean r

[jira] [Created] (KAFKA-4229) Controller can't start after serveral zk expired event

2016-09-29 Thread Pengwei (JIRA)
Pengwei created KAFKA-4229: -- Summary: Controller can't start after serveral zk expired event Key: KAFKA-4229 URL: https://issues.apache.org/jira/browse/KAFKA-4229 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-4229) Controller can't start after serveral zk expired event

2016-09-29 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Fix Version/s: (was: 0.10.1.0) > Controller can't start after serveral zk expired event >

[jira] [Updated] (KAFKA-4229) Controller can't start after serveral zk expired event

2016-09-29 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Fix Version/s: 0.10.1.0 > Controller can't start after serveral zk expired event > ---

[jira] [Commented] (KAFKA-4229) Controller can't start after serveral zk expired event

2016-09-29 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532241#comment-15532241 ] Pengwei commented on KAFKA-4229: I already have a patch for this issue, maybe the issue ca

[jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event

2016-09-29 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Summary: Controller can't start after several zk expired event (was: Controller can't start after serveral zk

[jira] [Updated] (KAFKA-4229) Controller can't start after several zk expired event

2016-09-29 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-4229: --- Description: We found the controller not started after several zk expired event in our test environment. By

[jira] [Commented] (KAFKA-4229) Controller can't start after several zk expired event

2016-10-13 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571265#comment-15571265 ] Pengwei commented on KAFKA-4229: We test it on 0.9.0.0, but I found the controller code ar

[jira] [Created] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

2015-11-27 Thread Pengwei (JIRA)
Pengwei created KAFKA-2903: -- Summary: FileMessageSet's read method maybe has problem when start is not zero Key: KAFKA-2903 URL: https://issues.apache.org/jira/browse/KAFKA-2903 Project: Kafka Issu

[jira] [Updated] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

2015-11-27 Thread Pengwei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-2903: --- Affects Version/s: 0.9.0.0 0.8.2.1 Fix Version/s: 0.9.0.0 > FileMessageSet's re