[jira] [Resolved] (KAFKA-6736) ReassignPartitionsClusterTest#shouldMoveSubsetOfPartitions is flaky

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6736. --- Resolution: Cannot Reproduce > ReassignPartitionsClusterTest#shouldMoveSubsetOfPartitions is flaky > -

[jira] [Resolved] (KAFKA-6734) TopicMetadataTest is flaky

2018-05-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6734. --- Resolution: Cannot Reproduce > TopicMetadataTest is flaky > -- > > Key

[jira] [Commented] (KAFKA-6730) Simplify state store recovery

2018-05-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16464298#comment-16464298 ] Ted Yu commented on KAFKA-6730: --- [~mjsax]: Can you take a look at the PR ? > Simplify state

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

2018-04-24 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 4/24/18 9:13 PM: Patch look

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

2018-04-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 4/24/18 9:12 PM: +1 from me

[jira] [Comment Edited] (KAFKA-6678) Upgrade dependencies with later release versions

2018-04-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16434768#comment-16434768 ] Ted Yu edited comment on KAFKA-6678 at 4/19/18 4:47 AM: Looks like

[jira] [Commented] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

2018-04-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441649#comment-16441649 ] Ted Yu commented on KAFKA-6775: --- SimpleBenchmark, around line 441 , similar issue: {code}

[jira] [Resolved] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes

2018-04-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6531. --- Resolution: Cannot Reproduce > SocketServerTest#closingChannelException fails sometimes >

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

2018-04-15 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 4/16/18 1:46 AM: Patch look

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

2018-04-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436669#comment-16436669 ] Ted Yu commented on KAFKA-6335: --- Haven't seen this test fail lately. > SimpleAclAuthorizerT

[jira] [Commented] (KAFKA-6678) Upgrade dependencies with later release versions

2018-04-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16434768#comment-16434768 ] Ted Yu commented on KAFKA-6678: --- Which release would drop support for Java 7 ? thanks > Up

[jira] [Created] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

2018-04-10 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6775: - Summary: AbstractProcessor created in SimpleBenchmark should call super#init Key: KAFKA-6775 URL: https://issues.apache.org/jira/browse/KAFKA-6775 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

2018-04-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16431677#comment-16431677 ] Ted Yu commented on KAFKA-6735: --- findbugs may take some time. Skipping findbugs is not for C

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

2018-04-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 4/10/18 4:05 AM: +1 was (

[jira] [Updated] (KAFKA-6736) ReassignPartitionsClusterTest#shouldMoveSubsetOfPartitions is flaky

2018-04-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6736: -- Description: Saw this from https://builds.apache.org/job/kafka-trunk-jdk8/2518/testReport/junit/kafka.admin/Rea

[jira] [Updated] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

2018-04-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6735: -- Description: Even when running single unit test, findbugs dependency would result in some time spent before the

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

2018-04-08 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] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-04-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 4/8/18 3:35 PM: --- Thanks for t

[jira] [Commented] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException

2018-04-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429416#comment-16429416 ] Ted Yu commented on KAFKA-6762: --- Here is related code: {code} if(readBuffer.capacity >=

[jira] [Commented] (KAFKA-6747) kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION

2018-04-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16426418#comment-16426418 ] Ted Yu commented on KAFKA-6747: --- https://github.com/apache/kafka/pull/4826 > kafka-streams

[jira] [Updated] (KAFKA-6747) kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION

2018-04-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6747: -- Description: [~frederica] running tests against kafka-streams 1.1 and get the following stack trace (everything

[jira] [Created] (KAFKA-6747) kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION

2018-04-04 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6747: - Summary: kafka-streams Invalid transition attempted from state READY to state ABORTING_TRANSACTION Key: KAFKA-6747 URL: https://issues.apache.org/jira/browse/KAFKA-6747 Project: Ka

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

2018-04-04 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-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed

2018-04-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6413: -- Description: In this thread: http://search-hadoop.com/m/Kafka/uyzND1J9Hizcxo0X?subj=Partition+reassignment+data

[jira] [Updated] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6531: -- Description: >From >https://builds.apache.org/job/kafka-trunk-jdk9/361/testReport/junit/kafka.network/SocketSer

[jira] [Updated] (KAFKA-6678) Upgrade dependencies with later release versions

2018-04-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6678: -- Component/s: build > Upgrade dependencies with later release versions >

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16422821#comment-16422821 ] Ted Yu commented on KAFKA-6681: --- 0.10.2.1 was quite old. It would be nice if you can reprod

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-04-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16422594#comment-16422594 ] Ted Yu commented on KAFKA-6681: --- I am digging into RangeAssignor. Meanwhile, please try out

[jira] [Moved] (KAFKA-6736) ReassignPartitionsClusterTest#shouldMoveSubsetOfPartitions is flaky

2018-04-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu moved HBASE-20325 to KAFKA-6736: --- Workflow: patch-available, re-open possible (was: no-reopen-closed, patch-avail)

[jira] [Updated] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

2018-04-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6735: -- Description: Even when running single unit test, findbugs dependency would result in some time spent before the

[jira] [Created] (KAFKA-6735) Document how to skip findbugs / checkstyle when running unit test

2018-04-01 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6735: - Summary: Document how to skip findbugs / checkstyle when running unit test Key: KAFKA-6735 URL: https://issues.apache.org/jira/browse/KAFKA-6735 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6734) TopicMetadataTest is flaky

2018-04-01 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6734: - Summary: TopicMetadataTest is flaky Key: KAFKA-6734 URL: https://issues.apache.org/jira/browse/KAFKA-6734 Project: Kafka Issue Type: Test Reporter: Ted Yu I

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-03-31 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421556#comment-16421556 ] Ted Yu commented on KAFKA-6681: --- I assume you use StickyAssignor. Can you switch to RoundRo

[jira] [Comment Edited] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-03-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16420634#comment-16420634 ] Ted Yu edited comment on KAFKA-6728 at 3/30/18 5:54 PM: Here is th

[jira] [Commented] (KAFKA-6728) Kafka Connect Header Null Pointer Exception

2018-03-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16420634#comment-16420634 ] Ted Yu commented on KAFKA-6728: --- Here is the related line where NPE was thrown: {code}

[jira] [Comment Edited] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails

2018-03-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407577#comment-16407577 ] Ted Yu edited comment on KAFKA-6698 at 3/27/18 3:17 PM: Test outpu

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

2018-03-26 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-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed

2018-03-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6413: -- Description: In this thread: http://search-hadoop.com/m/Kafka/uyzND1J9Hizcxo0X?subj=Partition+reassignment+data

[jira] [Created] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend

2018-03-26 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6716: - Summary: discardChannel should be released in MockSelector#completeSend Key: KAFKA-6716 URL: https://issues.apache.org/jira/browse/KAFKA-6716 Project: Kafka Issue Type: T

[jira] [Updated] (KAFKA-6678) Upgrade dependencies with later release versions

2018-03-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6678: -- Description: {code} The following dependencies have later release versions: - net.sourceforge.argparse4j:argpar

[jira] [Updated] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes

2018-03-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6531: -- Component/s: core > SocketServerTest#closingChannelException fails sometimes > -

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

2018-03-26 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] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

2018-03-26 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 edited comment on KAFKA-5802 at 3/26/18 4:43 PM: +1 from me

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

2018-03-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 3/26/18 4:42 PM: Thanks for

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

2018-03-26 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 3/26/18 4:42 PM: Patch look

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

2018-03-26 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 3/26/18 4:41 PM: lgtm was

[jira] [Commented] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails

2018-03-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407577#comment-16407577 ] Ted Yu commented on KAFKA-6698: --- Test output consisted of repeated occurrence of: {code} [20

[jira] [Created] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails

2018-03-21 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6698: - Summary: ConsumerBounceTest#testClose sometimes fails Key: KAFKA-6698 URL: https://issues.apache.org/jira/browse/KAFKA-6698 Project: Kafka Issue Type: Test Rep

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

2018-03-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-6681) Two instances of kafka consumer reading the same partition within a consumer group

2018-03-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407036#comment-16407036 ] Ted Yu commented on KAFKA-6681: --- {code} [2018-03-14 05:04:13,231] ERROR [ReplicaFetcherThrea

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

2018-03-19 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 edited comment on KAFKA-5802 at 3/20/18 1:02 AM: +1 from me

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

2018-03-18 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 3/19/18 1:28 AM: Patch look

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

2018-03-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 3/19/18 1:27 AM: Thanks for

[jira] [Updated] (KAFKA-6678) Upgrade dependencies with later release versions

2018-03-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6678: -- Attachment: k-update.txt > Upgrade dependencies with later release versions > --

[jira] [Created] (KAFKA-6678) Upgrade dependencies with later release versions

2018-03-18 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6678: - Summary: Upgrade dependencies with later release versions Key: KAFKA-6678 URL: https://issues.apache.org/jira/browse/KAFKA-6678 Project: Kafka Issue Type: Improvement

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

2018-03-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392410#comment-16392410 ] Ted Yu edited comment on KAFKA-6335 at 3/15/18 11:01 PM: - Happened

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

2018-03-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 3/14/18 8:36 PM: +1 was (

[jira] [Updated] (KAFKA-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed

2018-03-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6413: -- Description: In this thread: http://search-hadoop.com/m/Kafka/uyzND1J9Hizcxo0X?subj=Partition+reassignment+data

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

2018-03-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16397366#comment-16397366 ] Ted Yu commented on KAFKA-6647: --- The above code is paired with: {code} } fin

[jira] [Commented] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

2018-03-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16397347#comment-16397347 ] Ted Yu commented on KAFKA-5697: --- Looks like StreamThread.close() doesn't exist (after refact

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

2018-03-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394280#comment-16394280 ] Ted Yu commented on KAFKA-5889: --- >From >https://builds.apache.org/job/kafka-trunk-jdk9/462/

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

2018-03-09 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 3/10/18 12:42 AM: - Patch lo

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

2018-03-09 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-5943) Reduce dependency on mock in connector tests

2018-03-08 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: -- Labels: connector (was: connector mock) > Reduce dependency on mock in connector tests > --

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

2018-03-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu commented on KAFKA-5946: --- Thanks for taking it. > Give connector method parameter be

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

2018-03-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392410#comment-16392410 ] Ted Yu commented on KAFKA-6335: --- Sigh - the above link is no longer accessible. > SimpleAcl

[jira] [Commented] (KAFKA-6626) Performance bottleneck in Kafka Connect sendRecords

2018-03-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16391818#comment-16391818 ] Ted Yu commented on KAFKA-6626: --- There are alternatives in https://github.com/carrotsearch/h

[jira] [Updated] (KAFKA-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed

2018-03-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6413: -- Labels: json (was: ) > ReassignPartitionsCommand#parsePartitionReassignmentData() should give better > error m

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

2018-03-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 3/6/18 3:04 AM: --- lgtm was (

[jira] [Commented] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

2018-03-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16384490#comment-16384490 ] Ted Yu commented on KAFKA-4879: --- What about #2 listed by Jason above ? Should a KIP be draft

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

2018-03-02 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-6566) SourceTask#stop() not called after exception raised in poll()

2018-03-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16384159#comment-16384159 ] Ted Yu commented on KAFKA-6566: --- [~rhauch]: What would be the next step for this JIRA ? > S

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

2018-02-27 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: -- Labels: connector mock (was: connector) > Reduce dependency on mock in connector tests > --

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

2018-02-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5846: -- Component/s: clients > Use singleton NoOpConsumerRebalanceListener in subscribe() call where > listener is not

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

2018-02-25 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] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-02-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 2/24/18 3:27 AM: +1 was (

[jira] [Updated] (KAFKA-6413) ReassignPartitionsCommand#parsePartitionReassignmentData() should give better error message when JSON is malformed

2018-02-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6413: -- Description: In this thread: http://search-hadoop.com/m/Kafka/uyzND1J9Hizcxo0X?subj=Partition+reassignment+data

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

2018-02-21 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] [Resolved] (KAFKA-6228) Intermittent test failure in FetchRequestTest.testDownConversionWithConnectionFailure

2018-02-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6228. --- Resolution: Cannot Reproduce > Intermittent test failure in > FetchRequestTest.testDownConversionWithConnecti

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

2018-02-15 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 edited comment on KAFKA-5802 at 2/16/18 12:52 AM: - +1 from

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-02-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366404#comment-16366404 ] Ted Yu commented on KAFKA-6566: --- Thanks for the comment, Randall. I did a quick search but

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-02-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366341#comment-16366341 ] Ted Yu commented on KAFKA-6566: --- How about the following change ? {code} diff --git a/conne

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

2018-02-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: -- Component/s: KafkaConnect > Potential null dereference in DistributedHerder#reconfigureConnector() > ---

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

2018-02-12 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 2/12/18 8:49 PM: Patch look

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

2018-02-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359503#comment-16359503 ] Ted Yu commented on KAFKA-6024: --- Can committer review the PR ? > Consider moving validation

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

2018-02-10 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-6549) Deadlock while processing Controller Events

2018-02-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358729#comment-16358729 ] Ted Yu commented on KAFKA-6549: --- kafka-shutdown-hook didn't hold onto any lock. Can you tel

[jira] [Commented] (KAFKA-6544) kafka process should exit when it encounters "java.io.IOException: Too many open files"

2018-02-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16357419#comment-16357419 ] Ted Yu commented on KAFKA-6544: --- One option is to shutdown the process in SocketServer : {co

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

2018-02-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu reopened KAFKA-5889: --- As of 332e698ac9c74ce29317021b03a54512c92ac8b3 , I got: {code} kafka.metrics.MetricsTest > testMetricsLeak FAILED

[jira] [Created] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes

2018-02-04 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6531: - Summary: SocketServerTest#closingChannelException fails sometimes Key: KAFKA-6531 URL: https://issues.apache.org/jira/browse/KAFKA-6531 Project: Kafka Issue Type: Test

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

2018-02-02 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: -- Labels: connector newbie (was: connector newbie usability) > Give connector method parameter better name >

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

2018-01-31 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 edited comment on KAFKA-5802 at 2/1/18 1:24 AM: --- +1 was (Au

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

2018-01-31 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 2/1/18 1:16 AM: --- lgtm was (

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

2018-01-31 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-3184) Add Checkpoint for In-memory State Store

2018-01-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16344081#comment-16344081 ] Ted Yu commented on KAFKA-3184: --- bq. only do the checkpointing every N. flush calls This se

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

2018-01-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6232. --- Resolution: Cannot Reproduce > SaslSslAdminClientIntegrationTest sometimes fails > ---

[jira] [Comment Edited] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2018-01-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339071#comment-16339071 ] Ted Yu edited comment on KAFKA-6035 at 1/25/18 11:26 AM: - Since th

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2018-01-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339071#comment-16339071 ] Ted Yu commented on KAFKA-6035: --- Can you post the link to the pull request ? > Avoid creati

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

2018-01-24 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] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2018-01-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338615#comment-16338615 ] Ted Yu commented on KAFKA-6335: --- Haven't seen this for a while. > SimpleAclAuthorizerTest#t

<    1   2   3   4   5   6   >