[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

2015-08-03 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14652126#comment-14652126 ] Dong Lin commented on KAFKA-2388: - [~hachikuji] Sorry, my bad.. [~onurkaraman] is working

[jira] [Updated] (KAFKA-2332) Add quota metrics to old producer and consumer

2015-08-03 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2332: Attachment: KAFKA-2332_2015-08-03_18:22:53.patch > Add quota metrics to old producer and consumer >

[jira] [Commented] (KAFKA-2332) Add quota metrics to old producer and consumer

2015-08-03 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14652915#comment-14652915 ] Dong Lin commented on KAFKA-2332: - Updated reviewboard https://reviews.apache.org/r/36722/

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

2015-08-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658541#comment-14658541 ] Dong Lin commented on KAFKA-2390: - [~hachikuji] Per discussion with [~becket_qin], the mot

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

2015-08-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14658550#comment-14658550 ] Dong Lin commented on KAFKA-2390: - [~hachikuji] Yeah we definitely should do it. I will up

[jira] [Updated] (KAFKA-2390) Seek() should take a callback.

2015-08-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2390: Description: Currently seek is an async call. To have the same interface as other calls like commit(), seek(

[jira] [Updated] (KAFKA-2390) Seek() should take a callback.

2015-08-11 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2390: Status: Patch Available (was: Open) > Seek() should take a callback. > -- > >

[jira] [Created] (KAFKA-2436) log.retention.hours should be honored by LogManager

2015-08-15 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2436: --- Summary: log.retention.hours should be honored by LogManager Key: KAFKA-2436 URL: https://issues.apache.org/jira/browse/KAFKA-2436 Project: Kafka Issue Type: Bug

[jira] [Work started] (KAFKA-2436) log.retention.hours should be honored by LogManager

2015-08-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2436 started by Dong Lin. --- > log.retention.hours should be honored by LogManager > ---

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

2015-08-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700417#comment-14700417 ] Dong Lin commented on KAFKA-1690: - [~harsha_ch] Can you tell me the hash that I can use th

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

2015-08-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700469#comment-14700469 ] Dong Lin commented on KAFKA-1690: - [~sriharsha] I am not able to apply it again 63b89658b

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

2015-08-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700491#comment-14700491 ] Dong Lin commented on KAFKA-1690: - [~sriharsha] The patch KAFKA-1690_2015-08-17_12-20-53.p

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

2015-08-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700499#comment-14700499 ] Dong Lin commented on KAFKA-1690: - [~ijuma] Yes. I observed this as well. > Add SSL suppo

[jira] [Updated] (KAFKA-2436) log.retention.hours should be honored by LogManager

2015-08-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2436: Status: Patch Available (was: In Progress) > log.retention.hours should be honored by LogManager >

[jira] [Updated] (KAFKA-2436) log.retention.hours should be honored by LogManager

2015-08-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2436: Priority: Critical (was: Major) > log.retention.hours should be honored by LogManager > ---

[jira] [Created] (KAFKA-2442) QuotasTest should not fail when cpu is busy

2015-08-18 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2442: --- Summary: QuotasTest should not fail when cpu is busy Key: KAFKA-2442 URL: https://issues.apache.org/jira/browse/KAFKA-2442 Project: Kafka Issue Type: Bug R

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

2015-08-22 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14708137#comment-14708137 ] Dong Lin commented on KAFKA-2390: - [~nehanarkhede]Sure! Let me explain my understanding he

[jira] [Created] (KAFKA-2485) Allow producer performance to take properties from a file via --consumer.config command line parameter

2015-08-27 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2485: --- Summary: Allow producer performance to take properties from a file via --consumer.config command line parameter Key: KAFKA-2485 URL: https://issues.apache.org/jira/browse/KAFKA-2485

[jira] [Work started] (KAFKA-2485) Allow producer performance to take properties from a file via --consumer.config command line parameter

2015-08-27 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2485 started by Dong Lin. --- > Allow producer performance to take properties from a file via > --consumer.config comman

[jira] [Updated] (KAFKA-2485) Allow producer performance to take properties from a file via --consumer.config command line parameter

2015-08-27 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2485: Status: Patch Available (was: In Progress) > Allow producer performance to take properties from a file via

[jira] [Commented] (KAFKA-2485) Allow producer performance to take properties from a file via --producer.config command line parameter

2015-08-27 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717963#comment-14717963 ] Dong Lin commented on KAFKA-2485: - [~ewencp] I didn't add this to the Java producer perfor

[jira] [Assigned] (KAFKA-4089) KafkaProducer raises Batch Expired exception

2016-08-25 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-4089: --- Assignee: Dong Lin > KafkaProducer raises Batch Expired exception >

[jira] [Created] (KAFKA-4158) Reset quota to default value if quota override is deleted for a given clientId

2016-09-13 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-4158: --- Summary: Reset quota to default value if quota override is deleted for a given clientId Key: KAFKA-4158 URL: https://issues.apache.org/jira/browse/KAFKA-4158 Project: Kafka

[jira] [Updated] (KAFKA-4158) Reset quota to default value if quota override is deleted for a given clientId

2016-09-13 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-4158: Description: If user set a quota override and delete it override, Kafka will still use the quota override.

[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-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] [Commented] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

2017-04-28 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989453#comment-15989453 ] Dong Lin commented on KAFKA-4740: - I realized that this is a known problem since Feb after

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

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

[jira] [Created] (KAFKA-5335) Controller should batch updatePartitionReassignmentData() operation

2017-05-26 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5335: --- Summary: Controller should batch updatePartitionReassignmentData() operation Key: KAFKA-5335 URL: https://issues.apache.org/jira/browse/KAFKA-5335 Project: Kafka Issu

[jira] [Created] (KAFKA-5341) Add unavailablePartitionCount and per-partition Unavailable metrics (KIP-164)

2017-05-28 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5341: --- Summary: Add unavailablePartitionCount and per-partition Unavailable metrics (KIP-164) Key: KAFKA-5341 URL: https://issues.apache.org/jira/browse/KAFKA-5341 Project: Kafka

[jira] [Updated] (KAFKA-5341) Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics

2017-05-30 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5341: Description: We currently have under replicated partitions, but we do not have a metric to track the number

[jira] [Updated] (KAFKA-5341) Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics

2017-05-30 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5341: Summary: Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics (was: Add unavailablePartition

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

2017-06-02 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5367: --- Summary: Producer should not expiry topic from metadata cache if accumulator still has data for this topic Key: KAFKA-5367 URL: https://issues.apache.org/jira/browse/KAFKA-5367

[jira] [Created] (KAFKA-2527) System Test for Quotas in Ducktape

2015-09-08 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2527: --- Summary: System Test for Quotas in Ducktape Key: KAFKA-2527 URL: https://issues.apache.org/jira/browse/KAFKA-2527 Project: Kafka Issue Type: Test Reporter:

[jira] [Work started] (KAFKA-2527) System Test for Quotas in Ducktape

2015-09-08 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2527 started by Dong Lin. --- > System Test for Quotas in Ducktape > -- > >

[jira] [Updated] (KAFKA-2527) System Test for Quotas in Ducktape

2015-09-08 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2527: Issue Type: Sub-task (was: Test) Parent: KAFKA-2083 > System Test for Quotas in Ducktape >

[jira] [Created] (KAFKA-2528) Quota Performance Evaluation

2015-09-08 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2528: --- Summary: Quota Performance Evaluation Key: KAFKA-2528 URL: https://issues.apache.org/jira/browse/KAFKA-2528 Project: Kafka Issue Type: Sub-task Reporter: D

[jira] [Resolved] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-2528. - Resolution: Fixed > Quota Performance Evaluation > > > Key: K

[jira] [Work started] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2528 started by Dong Lin. --- > Quota Performance Evaluation > > > Key: KAFK

[jira] [Updated] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2528: Attachment: QuotaPerformanceEvaluation.pdf > Quota Performance Evaluation > > >

[jira] [Updated] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2528: Description: In this document we present the results of experiments we did at LinkedIn, to validate the basi

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14739488#comment-14739488 ] Dong Lin commented on KAFKA-2528: - I think this difference may be explained by the fact th

[jira] [Comment Edited] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14739505#comment-14739505 ] Dong Lin edited comment on KAFKA-2528 at 9/10/15 8:07 PM: -- Yeah I

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14739505#comment-14739505 ] Dong Lin commented on KAFKA-2528: - Yeah I think it is certainly doable, i.e. we can get ve

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14739612#comment-14739612 ] Dong Lin commented on KAFKA-2528: - I am a bit confused.. I thought you were referring to t

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14739886#comment-14739886 ] Dong Lin commented on KAFKA-2528: - Yeah I think that is a reasonable expectation. We have

[jira] [Reopened] (KAFKA-2528) Quota Performance Evaluation

2015-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened KAFKA-2528: - Explain the difference between broker throughput and quota when quota = 1 MBps > Quota Performance Evaluation

[jira] [Commented] (KAFKA-2552) Certain admin commands such as partition assignment fail on large clusters

2015-09-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14804710#comment-14804710 ] Dong Lin commented on KAFKA-2552: - Yeah I believe this duplicates KAFKA-2552. > Certain a

[jira] [Updated] (KAFKA-2390) OffsetOutOfRangeException should contain the Offset and Partition info.

2015-09-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2390: Resolution: Fixed Status: Resolved (was: Patch Available) > OffsetOutOfRangeException should contai

[jira] [Created] (KAFKA-2585) ConsoleConsumer should not hang infinitely upon exception

2015-09-27 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2585: --- Summary: ConsoleConsumer should not hang infinitely upon exception Key: KAFKA-2585 URL: https://issues.apache.org/jira/browse/KAFKA-2585 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2585) ConsoleConsumer should not hang infinitely upon exception

2015-09-27 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2585: Description: Due to imcompatibility beween Java 1.7 and Java 1.8, if Kafka ConsoleConsumer was compiled by

[jira] [Commented] (KAFKA-2573) Mirror maker system test hangs and eventually fails

2015-09-28 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933633#comment-14933633 ] Dong Lin commented on KAFKA-2573: - [~ijuma] Thanks for referring me to this ticket. Yes, I

[jira] [Assigned] (KAFKA-2621) nextOffsetMetadata should be changed after rolling a new log segment

2015-10-07 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-2621: --- Assignee: Dong Lin > nextOffsetMetadata should be changed after rolling a new log segment > -

[jira] [Updated] (KAFKA-2527) System Test for Quotas in Ducktape

2015-10-07 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2527: Fix Version/s: 0.9.0.0 > System Test for Quotas in Ducktape > -- > >

[jira] [Updated] (KAFKA-2171) System Test for Quotas

2015-10-07 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2171: Resolution: Duplicate Status: Resolved (was: Patch Available) Discard this patch in favor of quota

[jira] [Updated] (KAFKA-2527) System Test for Quotas in Ducktape

2015-10-07 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2527: Labels: quota (was: ) > System Test for Quotas in Ducktape > -- > >

[jira] [Created] (KAFKA-2660) Correct cleanableRatio calculation

2015-10-15 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2660: --- Summary: Correct cleanableRatio calculation Key: KAFKA-2660 URL: https://issues.apache.org/jira/browse/KAFKA-2660 Project: Kafka Issue Type: Bug Reporter:

[jira] [Updated] (KAFKA-2660) Correct cleanableRatio calculation

2015-10-15 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2660: Fix Version/s: 0.9.0.0 > Correct cleanableRatio calculation > -- > >

[jira] [Created] (KAFKA-2669) Fix LogCleanerIntegrationTest

2015-10-17 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-2669: --- Summary: Fix LogCleanerIntegrationTest Key: KAFKA-2669 URL: https://issues.apache.org/jira/browse/KAFKA-2669 Project: Kafka Issue Type: Bug Reporter: Dong

[jira] [Updated] (KAFKA-2668) Add a metric that records the total number of metrics

2015-10-17 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2668: Assignee: Dong Lin > Add a metric that records the total number of metrics > ---

[jira] [Updated] (KAFKA-2678) partition level lag metrics can be negative

2015-10-20 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2678: Assignee: Dong Lin > partition level lag metrics can be negative > -

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

2015-10-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984276#comment-14984276 ] Dong Lin commented on KAFKA-2528: - [~jkreps] Sorry for late reply. I just test the quota u

[jira] [Updated] (KAFKA-2528) Quota Performance Evaluation

2015-10-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2528: Attachment: (was: QuotaPerformanceEvaluation.pdf) > Quota Performance Evaluation > -

[jira] [Updated] (KAFKA-2528) Quota Performance Evaluation

2015-10-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2528: Attachment: QuotaPerformanceEvaluationRelease.pdf > Quota Performance Evaluation > -

[jira] [Commented] (KAFKA-2528) Quota Performance Evaluation

2015-10-31 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14984281#comment-14984281 ] Dong Lin commented on KAFKA-2528: - Updated the pdf to use latest evaluation results. > Qu

[jira] [Assigned] (KAFKA-2721) Avoid handling duplicate LeaderAndISR requests

2015-11-01 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-2721: --- Assignee: Dong Lin > Avoid handling duplicate LeaderAndISR requests > ---

[jira] [Resolved] (KAFKA-2528) Quota Performance Evaluation

2015-11-02 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-2528. - Resolution: Fixed > Quota Performance Evaluation > > > Key: K

[jira] [Assigned] (KAFKA-2751) Documentation for retention.ms is confusing

2015-11-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-2751: --- Assignee: Dong Lin > Documentation for retention.ms is confusing > --

[jira] [Resolved] (KAFKA-2751) Documentation for retention.ms is confusing

2015-11-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-2751. - Resolution: Won't Fix > Documentation for retention.ms is confusing >

[jira] [Commented] (KAFKA-2751) Documentation for retention.ms is confusing

2015-11-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992772#comment-14992772 ] Dong Lin commented on KAFKA-2751: - [~gwenshap] Ah I forgot that patch. Thanks for letting

[jira] [Commented] (KAFKA-2816) selector.poll() no longer throws IOException

2015-11-11 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15001768#comment-15001768 ] Dong Lin commented on KAFKA-2816: - I just checked the code. poll(timeout) calls select(tim

[jira] [Commented] (KAFKA-2888) Allow ConsoleConsumer to print a status update on some interval

2015-12-06 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15044200#comment-15044200 ] Dong Lin commented on KAFKA-2888: - [~ndimiduk] Can you submit a pull request via github? T

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012736#comment-14012736 ] Dong Lin commented on KAFKA-1472: - Created reviewboard against branch origin/trunk > Add

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012734#comment-14012734 ] Dong Lin commented on KAFKA-1472: - Created reviewboard against branch origin/trunk > Add

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472.patch > Add the compression ratio metrics in the new producer >

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472.patch > Add the compression ratio metrics in the new producer >

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012735#comment-14012735 ] Dong Lin commented on KAFKA-1472: - Created reviewboard against branch origin/trunk > Add

[jira] [Issue Comment Deleted] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Comment: was deleted (was: Created reviewboard against branch origin/trunk) > Add the compression ratio m

[jira] [Issue Comment Deleted] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Comment: was deleted (was: Created reviewboard against branch origin/trunk) > Add the compression ratio m

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: (was: KAFKA-1472.patch) > Add the compression ratio metrics in the new producer > -

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: (was: KAFKA-1472.patch) > Add the compression ratio metrics in the new producer > -

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472.patch > Add the compression ratio metrics in the new producer >

[jira] [Work started] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-1472 started by Dong Lin. > Add the compression ratio metrics in the new producer > - > >

[jira] [Work stopped] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-1472 stopped by Dong Lin. > Add the compression ratio metrics in the new producer > - > >

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012968#comment-14012968 ] Dong Lin commented on KAFKA-1472: - Created reviewboard https://reviews.apache.org/r/22063/

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472.patch > Add the compression ratio metrics in the new producer >

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: (was: KAFKA-1472.patch) > Add the compression ratio metrics in the new producer > -

[jira] [Issue Comment Deleted] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Comment: was deleted (was: Created reviewboard against branch origin/trunk) > Add the compression ratio m

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-05-29 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14012984#comment-14012984 ] Dong Lin commented on KAFKA-1472: - Hi Guozhang, thanks for noting the problem. The reviewb

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-06-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017906#comment-14017906 ] Dong Lin commented on KAFKA-1472: - Updated reviewboard https://reviews.apache.org/r/22063/

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-06-04 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472_2014-06-04_10:31:44.patch > Add the compression ratio metrics in the new producer >

[jira] [Updated] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-06-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1472: Attachment: KAFKA-1472_2014-06-05_22:42:23.patch > Add the compression ratio metrics in the new producer >

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-06-05 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14019600#comment-14019600 ] Dong Lin commented on KAFKA-1472: - Updated reviewboard https://reviews.apache.org/r/22063/

[jira] [Commented] (KAFKA-1472) Add the compression ratio metrics in the new producer

2014-06-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14027247#comment-14027247 ] Dong Lin commented on KAFKA-1472: - Thanks much! > Add the compression ratio metrics in th

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-06-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14041598#comment-14041598 ] Dong Lin commented on KAFKA-1477: - Created reviewboard against branch transactional_messa

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-06-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14041601#comment-14041601 ] Dong Lin commented on KAFKA-1477: - Created reviewboard https://reviews.apache.org/r/22905/

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-06-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Attachment: KAFKA-1477.patch > add authentication layer and initial JKS x509 implementation for brokers, >

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-06-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Attachment: KAFKA-1477.patch > add authentication layer and initial JKS x509 implementation for brokers, >

[jira] [Issue Comment Deleted] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-06-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Comment: was deleted (was: Created reviewboard against branch transactional_messaging) > add authenticati

[jira] [Issue Comment Deleted] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-06-24 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Comment: was deleted (was: Created reviewboard https://reviews.apache.org/r/22905/diff/ against branch ori

<    1   2   3   4   5   6   >