[jira] [Resolved] (KAFKA-12407) Document omitted Controller Health Metrics

2021-03-04 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-12407. -- Resolution: Fixed > Document omitted Controller Health Metrics > -

[jira] [Assigned] (KAFKA-9016) Warn when log dir stopped serving replicas

2019-11-08 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-9016: --- Assignee: kumar uttpal > Warn when log dir stopped serving replicas > --

[jira] [Resolved] (KAFKA-9016) Warn when log dir stopped serving replicas

2019-11-08 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-9016. - Resolution: Fixed > Warn when log dir stopped serving replicas >

[jira] [Resolved] (KAFKA-5367) Producer should not expiry topic from metadata cache if accumulator still has data for this topic

2017-06-26 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5367. - Resolution: Invalid > Producer should not expiry topic from metadata cache if accumulator still has > dat

[jira] [Created] (KAFKA-5521) Support replicas movement between log directories (KIP-113)

2017-06-26 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5521: --- Summary: Support replicas movement between log directories (KIP-113) Key: KAFKA-5521 URL: https://issues.apache.org/jira/browse/KAFKA-5521 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5521) Support replicas movement between log directories (KIP-113)

2017-06-28 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5521. - Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-5163 > Support replicas mo

[jira] [Commented] (KAFKA-5163) Support replicas movement between log directories (KIP-113)

2017-06-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069085#comment-16069085 ] Dong Lin commented on KAFKA-5163: - [~yuanjiali] ReplicaMoveThread will not grab lock for t

[jira] [Created] (KAFKA-5542) Improve Java doc for LeaderEpochFileCache.endOffsetFor()

2017-06-29 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5542: --- Summary: Improve Java doc for LeaderEpochFileCache.endOffsetFor() Key: KAFKA-5542 URL: https://issues.apache.org/jira/browse/KAFKA-5542 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5542) Improve Java doc for LeaderEpochFileCache.endOffsetFor()

2017-06-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5542: Issue Type: Improvement (was: Bug) > Improve Java doc for LeaderEpochFileCache.endOffsetFor() > ---

[jira] [Created] (KAFKA-5544) The LastStableOffsetLag metric should be removed when partition is deleted

2017-06-29 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5544: --- Summary: The LastStableOffsetLag metric should be removed when partition is deleted Key: KAFKA-5544 URL: https://issues.apache.org/jira/browse/KAFKA-5544 Project: Kafka

[jira] [Created] (KAFKA-5626) Producer should be able to negotiate ProduceRequest version with broker

2017-07-21 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5626: --- Summary: Producer should be able to negotiate ProduceRequest version with broker Key: KAFKA-5626 URL: https://issues.apache.org/jira/browse/KAFKA-5626 Project: Kafka

[jira] [Created] (KAFKA-5627) Reduce classes needed for LeaderAndIsrPartitionState and MetadataPartitionState

2017-07-22 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5627: --- Summary: Reduce classes needed for LeaderAndIsrPartitionState and MetadataPartitionState Key: KAFKA-5627 URL: https://issues.apache.org/jira/browse/KAFKA-5627 Project: Kafka

[jira] [Assigned] (KAFKA-5627) Reduce classes needed for LeaderAndIsrPartitionState and MetadataPartitionState

2017-07-22 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-5627: --- Assignee: Dong Lin > Reduce classes needed for LeaderAndIsrPartitionState and > MetadataPartitionSta

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-07-26 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102403#comment-16102403 ] Dong Lin commented on KAFKA-5663: - Thanks [~apurva]. I will look into this. > LogDirFailu

[jira] [Created] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113)

2017-08-02 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5694: --- Summary: Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113) Key: KAFKA-5694 URL: https://issues.apache.org/jira/browse/KAFKA-5694 Project: Kafka Issu

[jira] [Created] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

2017-08-02 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5695: --- Summary: Test DeleteRecordsRequest in AuthorizerIntegrationTest Key: KAFKA-5695 URL: https://issues.apache.org/jira/browse/KAFKA-5695 Project: Kafka Issue Type: Improv

[jira] [Created] (KAFKA-5710) KafkaAdminClient should remove inflight call correctly after response is received

2017-08-08 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5710: --- Summary: KafkaAdminClient should remove inflight call correctly after response is received Key: KAFKA-5710 URL: https://issues.apache.org/jira/browse/KAFKA-5710 Project: Kafka

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-08-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16122654#comment-16122654 ] Dong Lin commented on KAFKA-5663: - [~cmccabe] Sorry about it. Thanks for providing the log

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-08-14 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16126753#comment-16126753 ] Dong Lin commented on KAFKA-5663: - [~cmccabe] I just looked into the issue. It seems that

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-08-15 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16127744#comment-16127744 ] Dong Lin commented on KAFKA-5663: - [~cmccabe] It appears that the bug in ConsoleConsumer h

[jira] [Created] (KAFKA-5759) Allow user to specify relative path as log directory

2017-08-21 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5759: --- Summary: Allow user to specify relative path as log directory Key: KAFKA-5759 URL: https://issues.apache.org/jira/browse/KAFKA-5759 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

2017-08-22 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5767: --- Summary: Kafka server should halt if IBP < 1.0.0 and there is log directory failure Key: KAFKA-5767 URL: https://issues.apache.org/jira/browse/KAFKA-5767 Project: Kafka

[jira] [Updated] (KAFKA-5759) Allow user to specify relative path as log directory

2017-08-25 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5759: Fix Version/s: 1.0.0 > Allow user to specify relative path as log directory > --

[jira] [Updated] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

2017-08-25 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5767: Fix Version/s: 1.0.0 > Kafka server should halt if IBP < 1.0.0 and there is log directory failure >

[jira] [Updated] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

2017-08-25 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5767: Priority: Critical (was: Major) > Kafka server should halt if IBP < 1.0.0 and there is log directory failur

[jira] [Updated] (KAFKA-5759) Allow user to specify relative path as log directory

2017-08-25 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5759: Priority: Critical (was: Major) > Allow user to specify relative path as log directory > --

[jira] [Created] (KAFKA-5812) Represent logDir with case class where absolute path is required

2017-08-30 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5812: --- Summary: Represent logDir with case class where absolute path is required Key: KAFKA-5812 URL: https://issues.apache.org/jira/browse/KAFKA-5812 Project: Kafka Issue T

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

2017-08-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149954#comment-16149954 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] Can you be more specific which part or whic

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

2017-08-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150115#comment-16150115 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] Le's say we have a broker of 2 disks. Each

[jira] [Comment Edited] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

2017-08-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150115#comment-16150115 ] Dong Lin edited comment on KAFKA-4763 at 9/1/17 6:40 AM: - [~uncleG

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

2017-08-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150131#comment-16150131 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] The current design don't use remaining disk

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

2017-09-01 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150157#comment-16150157 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] Sorry, I am not ready to start a long discu

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

2017-09-01 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150161#comment-16150161 ] Dong Lin commented on KAFKA-4763: - And BTW, the current design already does what you sugge

[jira] [Created] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-09-04 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5829: --- Summary: Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion Key: KAFKA-5829 URL: https://issues.apache.org/jira/browse/KAFKA-5829 Pro

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-09-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5829: Description: The current Kafka implementation will cause slow startup after unclean shutdown. The time to l

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-09-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5829: Priority: Critical (was: Major) > Speedup broker startup after unclean shutdown by reducing unnecessary >

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-09-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5829: Fix Version/s: 1.0.0 > Speedup broker startup after unclean shutdown by reducing unnecessary > snapshot fil

[jira] [Created] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

2017-09-05 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5843: --- Summary: Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true Key: KAFKA-5843 URL: https://issues.apache.org/jira/browse/KAFKA-5843 Project: Kafka

[jira] [Created] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to brokers which starts very soon after shutdown

2017-09-06 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5845: --- Summary: KafkaController should send LeaderAndIsrRequest to brokers which starts very soon after shutdown Key: KAFKA-5845 URL: https://issues.apache.org/jira/browse/KAFKA-5845

[jira] [Updated] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown

2017-09-06 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5845: Summary: KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown (w

[jira] [Created] (KAFKA-5864) ReplicaFetcherThread.processPartitionData() should throw KafkaStorageException if replica is offline

2017-09-08 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5864: --- Summary: ReplicaFetcherThread.processPartitionData() should throw KafkaStorageException if replica is offline Key: KAFKA-5864 URL: https://issues.apache.org/jira/browse/KAFKA-5864

[jira] [Updated] (KAFKA-5864) ReplicaFetcherThread should not die due to replica in offline log directory

2017-09-08 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5864: Summary: ReplicaFetcherThread should not die due to replica in offline log directory (was: ReplicaFetcherTh

[jira] [Updated] (KAFKA-5864) ReplicaFetcherThread should not die if there is offline log directory

2017-09-08 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5864: Summary: ReplicaFetcherThread should not die if there is offline log directory (was: ReplicaFetcherThread.p

[jira] [Resolved] (KAFKA-5845) KafkaController should send LeaderAndIsrRequest to broker which starts very soon after shutdown

2017-09-08 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5845. - Resolution: Won't Fix > KafkaController should send LeaderAndIsrRequest to broker which starts very > soo

[jira] [Created] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5877: --- Summary: Controller should only update reassignment znode if there is change in the reassignment data Key: KAFKA-5877 URL: https://issues.apache.org/jira/browse/KAFKA-5877 Proj

[jira] [Updated] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5877: Description: I encountered a scenario where controller keeps printing the following stack trace repeatedly

[jira] [Created] (KAFKA-5878) Add sensor for queue size of the controller-event-thread

2017-09-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5878: --- Summary: Add sensor for queue size of the controller-event-thread Key: KAFKA-5878 URL: https://issues.apache.org/jira/browse/KAFKA-5878 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5879: Description: Currently controller can be very inefficient in handling IsrChangeNotification event because i

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5879: Description: Currently controller can be very inefficient in handling IsrChangeNotification event because i

[jira] [Created] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5879: --- Summary: Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event Key: KAFKA-5879 URL: https://issues.apache.org/jira/browse/KAFKA-5879

[jira] [Updated] (KAFKA-5163) Support replicas movement between log directories (KIP-113)

2017-09-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5163: Fix Version/s: 1.0.0 > Support replicas movement between log directories (KIP-113) > ---

[jira] [Updated] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5877: Fix Version/s: 1.0.0 > Controller should only update reassignment znode if there is change in the > reassig

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5879: Fix Version/s: 1.0.0 > Controller should read the latest IsrChangeNotification znodes when handling > IsrCh

[jira] [Updated] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

2017-09-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5843: Fix Version/s: 1.0.0 > Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to > true >

[jira] [Updated] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

2017-09-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5695: Fix Version/s: 1.0.0 > Test DeleteRecordsRequest in AuthorizerIntegrationTest >

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-21 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175242#comment-16175242 ] Dong Lin commented on KAFKA-5877: - [~tombentley] I didn't notice your comment earlier. The

[jira] [Issue Comment Deleted] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-21 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5877: Comment: was deleted (was: [~tombentley] I didn't notice your comment earlier. The issue is fixed with this

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-21 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175245#comment-16175245 ] Dong Lin commented on KAFKA-5877: - [~tombentley] I may have misunderstood your comment. Ar

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-22 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16176332#comment-16176332 ] Dong Lin commented on KAFKA-5877: - [~tombentley] Cool. Thanks! > Controller should only u

[jira] [Created] (KAFKA-5995) Rename AlterReplicaDir to AlterReplicaDirs

2017-09-29 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5995: --- Summary: Rename AlterReplicaDir to AlterReplicaDirs Key: KAFKA-5995 URL: https://issues.apache.org/jira/browse/KAFKA-5995 Project: Kafka Issue Type: Bug Re

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-10-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192636#comment-16192636 ] Dong Lin commented on KAFKA-5877: - This patch has been committed as part of https://githu

[jira] [Resolved] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-10-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5877. - Resolution: Fixed > Controller should only update reassignment znode if there is change in the > reassign

[jira] [Commented] (KAFKA-6027) System test failure: LogDirFailureTest

2017-10-09 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197259#comment-16197259 ] Dong Lin commented on KAFKA-6027: - [~ijuma] Thanks for creating this ticket. My changes wh

[jira] [Commented] (KAFKA-5634) Replica fetcher thread crashes due to OffsetOutOfRangeException

2017-10-09 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197300#comment-16197300 ] Dong Lin commented on KAFKA-5634: - [~ijuma] I just realized that I have missed most email

[jira] [Commented] (KAFKA-6027) System test failure: LogDirFailureTest

2017-10-09 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197310#comment-16197310 ] Dong Lin commented on KAFKA-6027: - [~tedyu] Cool. Thanks for the information. > System te

[jira] [Commented] (KAFKA-6027) System test failure: LogDirFailureTest

2017-10-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198508#comment-16198508 ] Dong Lin commented on KAFKA-6027: - [~ijuma] Yeah it is really convenient to setup system t

[jira] [Created] (KAFKA-6045) All access to log should fail if log is closed

2017-10-10 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6045: --- Summary: All access to log should fail if log is closed Key: KAFKA-6045 URL: https://issues.apache.org/jira/browse/KAFKA-6045 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-10-11 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200603#comment-16200603 ] Dong Lin commented on KAFKA-5877: - I am not sure about our policy of back-port. Maybe [~ij

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-10-14 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204711#comment-16204711 ] Dong Lin commented on KAFKA-5663: - [~junrao] I found the following exception in the broker

[jira] [Commented] (KAFKA-5871) bound the throttle time in byte rate quota

2017-10-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206901#comment-16206901 ] Dong Lin commented on KAFKA-5871: - [~junrao] I am not sure we can do this. The issue with

[jira] [Comment Edited] (KAFKA-5871) bound the throttle time in byte rate quota

2017-10-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206951#comment-16206951 ] Dong Lin edited comment on KAFKA-5871 at 10/17/17 3:13 AM: --- [~ju

[jira] [Commented] (KAFKA-5871) bound the throttle time in byte rate quota

2017-10-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206951#comment-16206951 ] Dong Lin commented on KAFKA-5871: - [~junrao] Yeah I read that comment. I think the actual

[jira] [Created] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

2017-10-18 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6078: --- Summary: Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster Key: KAFKA-6078 URL: https://issues.apache.org/jira/browse/KAFKA-6078 Project: Kafka

[jira] [Commented] (KAFKA-6093) replica dir not deleted after topic deletion

2017-10-19 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212078#comment-16212078 ] Dong Lin commented on KAFKA-6093: - [~junrao] Yes, your explanation is correct. This issue

[jira] [Reopened] (KAFKA-4218) Enable access to key in ValueTransformer

2018-10-01 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened KAFKA-4218: - Thanks for working on this [~jeyhunkarimov]! For KIP-149, currently there are 4 PRs: - [https://github.com/

[jira] [Commented] (KAFKA-7352) KIP-368: Allow SASL Connections to Periodically Re-Authenticate

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635353#comment-16635353 ] Dong Lin commented on KAFKA-7352: - PR can be found at [https://github.com/apache/kafka/pu

[jira] [Updated] (KAFKA-7352) KIP-368: Allow SASL Connections to Periodically Re-Authenticate

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7352: Fix Version/s: 2.1.0 > KIP-368: Allow SASL Connections to Periodically Re-Authenticate > --

[jira] [Resolved] (KAFKA-7406) Naming Join and Grouping Repartition Topics

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7406. - Resolution: Fixed > Naming Join and Grouping Repartition Topics > ---

[jira] [Commented] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635512#comment-16635512 ] Dong Lin commented on KAFKA-7464: - Moving this to 2.2.0 since the PR is not ready. > Fai

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Fix Version/s: (was: 2.1.0) 2.2.0 > Fail to shutdown ReplicaManager during broker cl

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Fix Version/s: (was: 2.2.0) 2.1.0 > Fail to shutdown ReplicaManager during broker cl

[jira] [Updated] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Priority: Blocker (was: Critical) > Fail to shutdown ReplicaManager during broker cleaned shutdown > -

[jira] [Issue Comment Deleted] (KAFKA-7464) Fail to shutdown ReplicaManager during broker cleaned shutdown

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7464: Comment: was deleted (was: Moving this to 2.2.0 since the PR is not ready.) > Fail to shutdown ReplicaMana

[jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7304: Fix Version/s: (was: 2.1.0) 2.2.0 > memory leakage in org.apache.kafka.common.networ

[jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7304: Fix Version/s: 2.1.1 > memory leakage in org.apache.kafka.common.network.Selector > ---

[jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5054: Fix Version/s: (was: 2.1.0) 2.1.1 2.2.0 > ChangeLoggingKeyValueBy

[jira] [Updated] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5054: Fix Version/s: (was: 2.1.1) (was: 2.2.0) 2.1.0 > ChangeLoggin

[jira] [Commented] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635532#comment-16635532 ] Dong Lin commented on KAFKA-5054: - [~damianguy] It seems that the PR has passed review bu

[jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3955: Fix Version/s: (was: 2.1.0) 2.2.0 > Kafka log recovery doesn't truncate logs on non-

[jira] [Updated] (KAFKA-4701) Allow kafka brokers to dynamically reload truststore without restarting.

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4701: Fix Version/s: (was: 2.1.0) 2.2.0 > Allow kafka brokers to dynamically reload trusts

[jira] [Updated] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3438: Fix Version/s: (was: 2.1.0) 2.2.0 > Rack Aware Replica Reassignment should warn of o

[jira] [Updated] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7037: Fix Version/s: (was: 2.1.0) > delete topic command replaces '+' from the topic name which leads incorre

[jira] [Updated] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6342: Fix Version/s: (was: 2.1.0) 2.2.0 > Move workaround for JSON parsing of non-escaped

[jira] [Updated] (KAFKA-7037) delete topic command replaces '+' from the topic name which leads incorrect topic deletion

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7037: Fix Version/s: 2.2.0 > delete topic command replaces '+' from the topic name which leads incorrect > topic

[jira] [Updated] (KAFKA-4808) send of null key to a compacted topic should throw error back to user

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4808: Fix Version/s: (was: 2.1.0) 2.2.0 > send of null key to a compacted topic should thr

[jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4850: Fix Version/s: (was: 2.1.0) 2.2.0 > RocksDb cannot use Bloom Filters > -

[jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635545#comment-16635545 ] Dong Lin commented on KAFKA-3297: - Since there has been no activity on the PR for several

[jira] [Updated] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3297: Fix Version/s: (was: 2.1.0) 2.2.0 > More optimally balanced partition assignment str

[jira] [Updated] (KAFKA-5952) Refactor Consumer Fetcher metrics

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5952: Fix Version/s: (was: 2.1.0) 2.2.0 > Refactor Consumer Fetcher metrics >

[jira] [Updated] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

2018-10-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5951: Fix Version/s: (was: 2.1.0) 2.2.0 > Autogenerate Producer RecordAccumulator metrics

  1   2   3   4   5   6   7   >