[jira] [Updated] (KAFKA-6074) Use ZookeeperClient in ReplicaManager and Partition

2017-10-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6074: -- Attachment: 6074.v1.txt > Use ZookeeperClient in ReplicaManager and Partition >

[jira] [Commented] (KAFKA-6074) Use ZookeeperClient in ReplicaManager and Partition

2017-10-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216193#comment-16216193 ] Ted Yu commented on KAFKA-6074: --- {code} val zkPath = new ZkPath(zkClientWrap) {code} Befor

[jira] [Commented] (KAFKA-5889) MetricsTest is flaky

2017-10-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16217277#comment-16217277 ] Ted Yu commented on KAFKA-5889: --- The test didn't fail recently. > MetricsTest is flaky > --

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2017-10-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Priority: Minor (was: Major) > Reduce dependency on mock in connector tests > -

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2017-10-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Updated] (KAFKA-6075) Kafka cannot recover after an unclean shutdown on Windows

2017-10-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6075: -- Attachment: 6075.v4 > Kafka cannot recover after an unclean shutdown on Windows > --

[jira] [Commented] (KAFKA-6119) Silent Data Loss in Kafka011 Transactional Producer

2017-10-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16219620#comment-16219620 ] Ted Yu commented on KAFKA-6119: --- Looks like the new state shouldn't be hardcoded. How about

[jira] [Comment Edited] (KAFKA-6119) Silent Data Loss in Kafka011 Transactional Producer

2017-10-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16219620#comment-16219620 ] Ted Yu edited comment on KAFKA-6119 at 10/25/17 10:08 PM: -- Looks

[jira] [Issue Comment Deleted] (KAFKA-6119) Silent Data Loss in Kafka011 Transactional Producer

2017-10-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6119: -- Comment: was deleted (was: Looks like the new state shouldn't be hardcoded. How about the following change ? {co

[jira] [Commented] (KAFKA-6132) KafkaProducer.initTransactions dead locks

2017-10-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220951#comment-16220951 ] Ted Yu commented on KAFKA-6132: --- Does KAFKA-6042: 'Avoid deadlock between two groups with de

[jira] [Commented] (KAFKA-6132) KafkaProducer.initTransactions dead locks

2017-10-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220986#comment-16220986 ] Ted Yu commented on KAFKA-6132: --- The RC is in maven staging repo. > KafkaProducer.initTrans

[jira] [Commented] (KAFKA-6132) KafkaProducer.initTransactions dead locks

2017-10-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221009#comment-16221009 ] Ted Yu commented on KAFKA-6132: --- Add this to your pom.xml : {code} sta

[jira] [Created] (KAFKA-6135) TransactionsTest#testFencingOnCommit may fail due to unexpected KafkaException

2017-10-26 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6135: - Summary: TransactionsTest#testFencingOnCommit may fail due to unexpected KafkaException Key: KAFKA-6135 URL: https://issues.apache.org/jira/browse/KAFKA-6135 Project: Kafka

[jira] [Updated] (KAFKA-6135) TransactionsTest#testFencingOnCommit may fail due to unexpected KafkaException

2017-10-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6135: -- Attachment: 6135.out Test output . > TransactionsTest#testFencingOnCommit may fail due to unexpected KafkaExcep

[jira] [Commented] (KAFKA-6109) ResetIntegrationTest may fail due to IllegalArgumentException

2017-10-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222478#comment-16222478 ] Ted Yu commented on KAFKA-6109: --- >From https://builds.apache.org/job/kafka-1.0-jdk7/62 : {co

[jira] [Comment Edited] (KAFKA-5889) MetricsTest is flaky

2017-10-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16217277#comment-16217277 ] Ted Yu edited comment on KAFKA-5889 at 10/27/17 2:57 PM: - >From ht

[jira] [Issue Comment Deleted] (KAFKA-6109) ResetIntegrationTest may fail due to IllegalArgumentException

2017-10-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6109: -- Comment: was deleted (was: From https://builds.apache.org/job/kafka-1.0-jdk7/62 : {code} org.apache.kafka.stream

[jira] [Created] (KAFKA-6137) RestoreIntegrationTest sometimes fails with assertion error

2017-10-27 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6137: - Summary: RestoreIntegrationTest sometimes fails with assertion error Key: KAFKA-6137 URL: https://issues.apache.org/jira/browse/KAFKA-6137 Project: Kafka Issue Type: Test

[jira] [Resolved] (KAFKA-6109) ResetIntegrationTest may fail due to IllegalArgumentException

2017-10-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6109. --- Resolution: Cannot Reproduce > ResetIntegrationTest may fail due to IllegalArgumentException > ---

[jira] [Commented] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

2017-10-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222620#comment-16222620 ] Ted Yu commented on KAFKA-6024: --- lgtm > Consider moving validation in KafkaConsumer ahead o

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

2017-10-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16225395#comment-16225395 ] Ted Yu commented on KAFKA-6144: --- Please prepare a KIP. > Allow state stores to serve stale

[jira] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

2017-11-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212069#comment-16212069 ] Ted Yu edited comment on KAFKA-5802 at 11/1/17 5:15 PM: Thanks for

[jira] [Updated] (KAFKA-5946) Give connector method parameter better name

2017-11-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5946: -- Description: During the development of KAFKA-5657, there were several iterations where method call didn't match

[jira] [Commented] (KAFKA-6158) CONSUMER-ID and HOST values are concatenated if the CONSUMER-ID is > 50 chars

2017-11-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235890#comment-16235890 ] Ted Yu commented on KAFKA-6158: --- How about shifting consumer Id column after the following t

[jira] [Resolved] (KAFKA-6137) RestoreIntegrationTest sometimes fails with assertion error

2017-11-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6137. --- Resolution: Cannot Reproduce > RestoreIntegrationTest sometimes fails with assertion error > -

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2017-11-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real lo

[jira] [Commented] (KAFKA-6164) ClientQuotaManager threads prevent shutdown when encountering an error loading logs

2017-11-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16236900#comment-16236900 ] Ted Yu commented on KAFKA-6164: --- ThrottledRequestReaper extends ShutdownableThread where {co

[jira] [Comment Edited] (KAFKA-6164) ClientQuotaManager threads prevent shutdown when encountering an error loading logs

2017-11-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16236900#comment-16236900 ] Ted Yu edited comment on KAFKA-6164 at 11/3/17 12:59 AM: - Throttle

[jira] [Commented] (KAFKA-5889) MetricsTest is flaky

2017-11-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16237005#comment-16237005 ] Ted Yu commented on KAFKA-5889: --- https://builds.apache.org/job/kafka-trunk-jdk7/2942 : {code

[jira] [Commented] (KAFKA-6166) Streams configuration requires consumer. and producer. in order to be read

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16237846#comment-16237846 ] Ted Yu commented on KAFKA-6166: --- How about populating the first two configs with the value f

[jira] [Commented] (KAFKA-6167) Timestamp on streams directory contains a colon, which is an illegal character

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16237856#comment-16237856 ] Ted Yu commented on KAFKA-6167: --- Any suggestion for a replacement ? Semicolon ? > Timestamp

[jira] [Commented] (KAFKA-6168) Connect Schema comparison is slow for large schemas

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16238561#comment-16238561 ] Ted Yu commented on KAFKA-6168: --- Can I work on this ? > Connect Schema comparison is slow f

[jira] [Updated] (KAFKA-6168) Connect Schema comparison is slow for large schemas

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6168: -- Attachment: 6168.v1.txt > Connect Schema comparison is slow for large schemas >

[jira] [Comment Edited] (KAFKA-6168) Connect Schema comparison is slow for large schemas

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16238561#comment-16238561 ] Ted Yu edited comment on KAFKA-6168 at 11/3/17 11:35 PM: - bq. cons

[jira] [Updated] (KAFKA-6074) Use ZookeeperClient in ReplicaManager and Partition

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6074: -- Attachment: 6074.v10.txt > Use ZookeeperClient in ReplicaManager and Partition > ---

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2017-11-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2017-11-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 11/5/17 3:32 AM: Patch look

[jira] [Commented] (KAFKA-5973) ShutdownableThread catching errors can lead to partial hard to diagnose broker failure

2017-11-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240971#comment-16240971 ] Ted Yu commented on KAFKA-5973: --- Currently not - there is no consensus for the solution. >

[jira] [Comment Edited] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

2017-11-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222620#comment-16222620 ] Ted Yu edited comment on KAFKA-6024 at 11/8/17 1:40 AM: +1 was (

[jira] [Created] (KAFKA-6193) ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics fails sometimes

2017-11-09 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6193: - Summary: ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics fails sometimes Key: KAFKA-6193 URL: https://issues.apache.org/jira/browse/KAFKA-6193

[jira] [Updated] (KAFKA-6193) ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics fails sometimes

2017-11-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6193: -- Attachment: 6193.out > ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopic

[jira] [Resolved] (KAFKA-6135) TransactionsTest#testFencingOnCommit may fail due to unexpected KafkaException

2017-11-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6135. --- Resolution: Cannot Reproduce > TransactionsTest#testFencingOnCommit may fail due to unexpected KafkaException

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16246846#comment-16246846 ] Ted Yu commented on KAFKA-6194: --- {code} [2017-11-09 15:32:05,622] FATAL Shutdown broker beca

[jira] [Comment Edited] (KAFKA-6194) Server crash while deleting segments

2017-11-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16246846#comment-16246846 ] Ted Yu edited comment on KAFKA-6194 at 11/10/17 6:18 PM: - {code} [

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-11-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248546#comment-16248546 ] Ted Yu commented on KAFKA-6199: --- Robin: Can you attach heap dump ? Thanks > Single broker

[jira] [Commented] (KAFKA-4262) Intermittent unit test failure ReassignPartitionsClusterTest.shouldExecuteThrottledReassignment

2017-11-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248600#comment-16248600 ] Ted Yu commented on KAFKA-4262: --- Saw the following in 0.11.0.2 RC0 : {code} kafka.admin.Reas

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2017-11-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real log

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2017-11-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Commented] (KAFKA-6194) Server crash while deleting segments

2017-11-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16249807#comment-16249807 ] Ted Yu commented on KAFKA-6194: --- bq. throw an exception if the file does not exist after Se

[jira] [Created] (KAFKA-6215) KafkaStreamsTest fails in trunk

2017-11-15 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6215: - Summary: KafkaStreamsTest fails in trunk Key: KAFKA-6215 URL: https://issues.apache.org/jira/browse/KAFKA-6215 Project: Kafka Issue Type: Test Reporter: Ted Yu

[jira] [Commented] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

2017-11-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16254503#comment-16254503 ] Ted Yu commented on KAFKA-6024: --- Can you ping a committer ? :-) > Consider moving validatio

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2017-11-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 11/17/17 5:37 AM: - Patch lo

[jira] [Created] (KAFKA-6228) Intermittent test failure in FetchRequestTest.testDownConversionWithConnectionFailure

2017-11-17 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6228: - Summary: Intermittent test failure in FetchRequestTest.testDownConversionWithConnectionFailure Key: KAFKA-6228 URL: https://issues.apache.org/jira/browse/KAFKA-6228 Project: Kafka

[jira] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

2017-11-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212069#comment-16212069 ] Ted Yu edited comment on KAFKA-5802 at 11/18/17 12:43 AM: -- Thanks

[jira] [Created] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails

2017-11-18 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6232: - Summary: SaslSslAdminClientIntegrationTest sometimes fails Key: KAFKA-6232 URL: https://issues.apache.org/jira/browse/KAFKA-6232 Project: Kafka Issue Type: Test

[jira] [Updated] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails

2017-11-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6232: -- Attachment: saslSslAdminClientIntegrationTest-203.out > SaslSslAdminClientIntegrationTest sometimes fails >

[jira] [Commented] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

2017-11-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16258162#comment-16258162 ] Ted Yu commented on KAFKA-4064: --- [~xvrl]: Do you have time to move this forward ? Thanks >

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2017-11-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real lo

[jira] [Commented] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails

2017-11-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16260942#comment-16260942 ] Ted Yu commented on KAFKA-6232: --- >From https://builds.apache.org/job/kafka-trunk-jdk8/2225/t

[jira] [Updated] (KAFKA-5946) Give connector method parameter better name

2017-11-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5946: -- Description: During the development of KAFKA-5657, there were several iterations where method call didn't match

[jira] [Issue Comment Deleted] (KAFKA-6074) Use ZookeeperClient in ReplicaManager and Partition

2017-11-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6074: -- Comment: was deleted (was: In ReplicationUtils#propagateIsrChanges() (called by ReplicaManager#maybePropagateIs

[jira] [Commented] (KAFKA-6168) Connect Schema comparison is slow for large schemas

2017-11-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16265861#comment-16265861 ] Ted Yu commented on KAFKA-6168: --- bq. it might be worth considering having each instance prec

[jira] [Commented] (KAFKA-6168) Connect Schema comparison is slow for large schemas

2017-11-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16265893#comment-16265893 ] Ted Yu commented on KAFKA-6168: --- Thanks for the comment. bq. impact on allocations & GC I

[jira] [Updated] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

2017-11-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6024: -- Description: In several methods, parameter validation is done after calling acquireAndEnsureOpen() : {code}

[jira] [Updated] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

2017-11-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6288: -- Attachment: 6288.v1.txt Cloning Kafka repo is slow (in China). How does the patch look ? > Broken symlink inte

[jira] [Comment Edited] (KAFKA-6288) Broken symlink interrupts scanning the plugin path

2017-11-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16273872#comment-16273872 ] Ted Yu edited comment on KAFKA-6288 at 12/1/17 3:29 AM: How does t

[jira] [Created] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException

2017-12-02 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6300: - Summary: SelectorTest may fail with ConcurrentModificationException Key: KAFKA-6300 URL: https://issues.apache.org/jira/browse/KAFKA-6300 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-12-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16275818#comment-16275818 ] Ted Yu commented on KAFKA-6199: --- JmxReporter$KafkaMbean showed up near the top in the histo

[jira] [Updated] (KAFKA-6193) Only delete reassign_partitions znode after reassignment is complete

2017-12-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6193: -- Summary: Only delete reassign_partitions znode after reassignment is complete (was: ReassignPartitionsClusterT

[jira] [Commented] (KAFKA-6193) Only delete reassign_partitions znode after reassignment is complete

2017-12-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16275982#comment-16275982 ] Ted Yu commented on KAFKA-6193: --- Updated JIRA title according to Ismael's discovery. > Only

[jira] [Created] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2017-12-03 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6303: - Summary: Potential lack of synchronization in NioEchoServer#AcceptorThread Key: KAFKA-6303 URL: https://issues.apache.org/jira/browse/KAFKA-6303 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute()

2017-12-04 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6307: - Summary: mBeanName should be removed before returning from JmxReporter#removeAttribute() Key: KAFKA-6307 URL: https://issues.apache.org/jira/browse/KAFKA-6307 Project: Kafka

[jira] [Commented] (KAFKA-6199) Single broker with fast growing heap usage

2017-12-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276869#comment-16276869 ] Ted Yu commented on KAFKA-6199: --- Looking at the second histogram, JmxReporter$KafkaMbean did

[jira] [Commented] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute()

2017-12-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277081#comment-16277081 ] Ted Yu commented on KAFKA-6307: --- Go ahead > mBeanName should be removed before returning fr

[jira] [Commented] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2017-12-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16277084#comment-16277084 ] Ted Yu commented on KAFKA-6303: --- Go ahead > Potential lack of synchronization in NioEchoSer

[jira] [Commented] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

2017-12-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16281270#comment-16281270 ] Ted Yu commented on KAFKA-6322: --- Seems to be same problem as KAFKA-6075 > Error deleting lo

[jira] [Commented] (KAFKA-6325) Producer.flush() doesn't throw exception on timeout

2017-12-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282030#comment-16282030 ] Ted Yu commented on KAFKA-6325: --- I assume you have modified your producer code to accommodat

[jira] [Commented] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

2017-12-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282120#comment-16282120 ] Ted Yu commented on KAFKA-6322: --- FileSystemException was encountered in Dongyan's case (whic

[jira] [Comment Edited] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

2017-12-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282120#comment-16282120 ] Ted Yu edited comment on KAFKA-6322 at 12/7/17 5:20 PM: FileSystem

[jira] [Commented] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

2017-12-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16282186#comment-16282186 ] Ted Yu commented on KAFKA-6322: --- Edited previous comment. Since Dongyan's case was not for f

[jira] [Commented] (KAFKA-6307) mBeanName should be removed before returning from JmxReporter#removeAttribute()

2017-12-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283925#comment-16283925 ] Ted Yu commented on KAFKA-6307: --- Siva: I have some cycles now. If you haven't started, can I

[jira] [Created] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-08 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6335: - Summary: SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently Key: KAFKA-6335 URL: https://issues.apache.org/jira/browse/KAFKA-6335 Project:

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284862#comment-16284862 ] Ted Yu commented on KAFKA-6335: --- Diff shows that the following was missing in actual Set: {c

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286612#comment-16286612 ] Ted Yu commented on KAFKA-6335: --- Same error: https://builds.apache.org/job/kafka-trunk-jdk8/

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16289550#comment-16289550 ] Ted Yu commented on KAFKA-6335: --- SimpleAclAuthorizer#updateResourceAcls() returns boolean, i

[jira] [Updated] (KAFKA-6232) SaslSslAdminClientIntegrationTest sometimes fails

2017-12-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6232: -- Labels: security (was: ) > SaslSslAdminClientIntegrationTest sometimes fails >

[jira] [Updated] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

2017-12-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6366: -- Attachment: 6366.v1.txt First attempt for fixing the stack overflow > StackOverflowError in kafka-coordinator-h

[jira] [Created] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException

2017-12-14 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6370: - Summary: MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException Key: KAFKA-6370 URL: https://issues.apache.org/jira/browse/KAFKA-6370 Project: Kafk

[jira] [Updated] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2017-12-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6303: -- Component/s: network > Potential lack of synchronization in NioEchoServer#AcceptorThread > -

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2017-12-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real lo

[jira] [Created] (KAFKA-6384) TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException

2017-12-18 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6384: - Summary: TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException Key: KAFKA-6384 URL: https://issues.apache.org/jira/browse/KAFKA-6384 Project: Kafka

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

2017-12-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16298880#comment-16298880 ] Ted Yu commented on KAFKA-6366: --- {code} completedOffsetCommits.add(new

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

2017-12-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16298915#comment-16298915 ] Ted Yu commented on KAFKA-6366: --- Should I log another JIRA for the above ? One aspect we ne

[jira] [Comment Edited] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

2017-12-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16298915#comment-16298915 ] Ted Yu edited comment on KAFKA-6366 at 12/21/17 12:19 AM: -- Should

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2017-12-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16299303#comment-16299303 ] Ted Yu commented on KAFKA-6335: --- If needed, we can add logging into codebase so that it is e

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2017-12-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

2017-12-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16300303#comment-16300303 ] Ted Yu commented on KAFKA-6366: --- Including the cause in the log can be done in your PR. Tha

[jira] [Commented] (KAFKA-3184) Add Checkpoint for In-memory State Store

2017-12-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16300417#comment-16300417 ] Ted Yu commented on KAFKA-3184: --- >From InMemoryKeyValueStore : {code} public void flush(

[jira] [Issue Comment Deleted] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

2017-12-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6024: -- Comment: was deleted (was: Can you ping a committer ? :-)) > Consider moving validation in KafkaConsumer ahead

[jira] [Commented] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

2017-12-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302643#comment-16302643 ] Ted Yu commented on KAFKA-5802: --- lgtm > ScramServerCallbackHandler#handle should check user

<    1   2   3   4   5   6   >