[jira] [Updated] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5911: -- Attachment: 5911.v1.txt I have run KafkaAdminClientTest thru the patch which passed. > Avoid creation of extra

[jira] [Created] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient

Ted Yu created KAFKA-5911: - Summary: Avoid creation of extra Map for futures in KafkaAdminClient Key: KAFKA-5911 URL: https://issues.apache.org/jira/browse/KAFKA-5911 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5916) Upgrade rocksdb dependency to 5.7.3

Ted Yu created KAFKA-5916: - Summary: Upgrade rocksdb dependency to 5.7.3 Key: KAFKA-5916 URL: https://issues.apache.org/jira/browse/KAFKA-5916 Project: Kafka Issue Type: Improvement

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

[ 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}

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

[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177046#comment-16177046 ] Ted Yu commented on KAFKA-5889: --- As of commit 125d8d6f70829b9a0dbeabfef8f6b2df438dc12b , I got: {code}

[jira] [Resolved] (KAFKA-5821) Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls

[ https://issues.apache.org/jira/browse/KAFKA-5821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5821. --- Resolution: Cannot Reproduce > Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls >

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

Ted Yu created KAFKA-5946: - Summary: Give connector method parameter better name Key: KAFKA-5946 URL: https://issues.apache.org/jira/browse/KAFKA-5946 Project: Kafka Issue Type: Improvement

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

Ted Yu created KAFKA-5943: - Summary: Reduce dependency on mock in connector tests Key: KAFKA-5943 URL: https://issues.apache.org/jira/browse/KAFKA-5943 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174046#comment-16174046 ] Ted Yu commented on KAFKA-5657: --- Can the newbie label be taken off considering how confusing the connector

[jira] [Commented] (KAFKA-5156) Options for handling exceptions in streams

[ https://issues.apache.org/jira/browse/KAFKA-5156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16169515#comment-16169515 ] Ted Yu commented on KAFKA-5156: --- OffsetMetadataTooLargeException appears in both categories of exceptions.

[jira] [Commented] (KAFKA-5896) Kafka Connect task threads never interrupted

[ https://issues.apache.org/jira/browse/KAFKA-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166907#comment-16166907 ] Ted Yu commented on KAFKA-5896: --- Good find. Mind sending a PR (hopefully with test showing the

[jira] [Commented] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165653#comment-16165653 ] Ted Yu commented on KAFKA-5657: --- >From PR: bq. Who'd have thought that adding the connector type would get

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

Ted Yu created KAFKA-5889: - Summary: MetricsTest is flaky Key: KAFKA-5889 URL: https://issues.apache.org/jira/browse/KAFKA-5889 Project: Kafka Issue Type: Test Reporter: Ted Yu The

[jira] [Commented] (KAFKA-5898) Client consume more than one time a message

[ https://issues.apache.org/jira/browse/KAFKA-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167127#comment-16167127 ] Ted Yu commented on KAFKA-5898: --- Just curious: 0.11.0.1 has been released. Is this reproducible using

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

[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5802: -- Description: {code} String username = null; for (Callback callback : callbacks) {

[jira] [Resolved] (KAFKA-5840) TransactionsTest#testBasicTransactions sometimes hangs

[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5840. --- Resolution: Cannot Reproduce > TransactionsTest#testBasicTransactions sometimes hangs >

[jira] [Resolved] (KAFKA-5916) Upgrade rocksdb dependency to 5.8

[ https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5916. --- Resolution: Duplicate With KAFKA-5576 > Upgrade rocksdb dependency to 5.8 >

[jira] [Commented] (KAFKA-6020) Broker side filtering

[ https://issues.apache.org/jira/browse/KAFKA-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195223#comment-16195223 ] Ted Yu commented on KAFKA-6020: --- This needs a KIP, right ? > Broker side filtering > -

[jira] [Created] (KAFKA-6023) ThreadCache#sizeBytes() should check overflow

Ted Yu created KAFKA-6023: - Summary: ThreadCache#sizeBytes() should check overflow Key: KAFKA-6023 URL: https://issues.apache.org/jira/browse/KAFKA-6023 Project: Kafka Issue Type: Bug

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

Ted Yu created KAFKA-6024: - Summary: Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen() Key: KAFKA-6024 URL: https://issues.apache.org/jira/browse/KAFKA-6024 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196244#comment-16196244 ] Ted Yu commented on KAFKA-6024: --- Go ahead. > Consider moving validation in KafkaConsumer ahead of call to

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

[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5946: -- Labels: connector (was: ) > Give connector method parameter better name >

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

[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188721#comment-16188721 ] Ted Yu commented on KAFKA-5889: ---

[jira] [Resolved] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5842. --- Resolution: Cannot Reproduce > QueryableStateIntegrationTest may fail with JDK 7 >

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

[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu commented on KAFKA-5846: --- lgtm > Use singleton NoOpConsumerRebalanceListener in subscribe() call

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

[ https://issues.apache.org/jira/browse/KAFKA-6027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197283#comment-16197283 ] Ted Yu commented on KAFKA-6027: --- In any of the link where LogDirFailureTest failed, there would be a link

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198944#comment-16198944 ] Ted Yu commented on KAFKA-6043: --- 0.8.1.1 was very old. Are you able to try newer release ? > Kafka 8.1.1 -

[jira] [Commented] (KAFKA-6046) DeleteRecordsRequest to a non-leader

[ https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198932#comment-16198932 ] Ted Yu commented on KAFKA-6046: --- Looking at core/src/main/scala/kafka/server/DelayedDeleteRecords.scala :

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199292#comment-16199292 ] Ted Yu commented on KAFKA-6043: --- Did you see who is holding 0x00076b2e1508 ? > Kafka 8.1.1 - >

[jira] [Commented] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199291#comment-16199291 ] Ted Yu commented on KAFKA-6043: --- bq. locked <0x00076a922c40> (a java.lang.Object) This is the

[jira] [Updated] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

[ https://issues.apache.org/jira/browse/KAFKA-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6043: -- Attachment: 6043.v1 > Kafka 8.1.1 - >

[jira] [Commented] (KAFKA-6047) Allow retries configuration for InternalTopicManager

[ https://issues.apache.org/jira/browse/KAFKA-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205108#comment-16205108 ] Ted Yu commented on KAFKA-6047: --- Does this require a KIP ? > Allow retries configuration for

[jira] [Commented] (KAFKA-6063) StreamsException is thrown after the changing `partitions`

[ https://issues.apache.org/jira/browse/KAFKA-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205109#comment-16205109 ] Ted Yu commented on KAFKA-6063: --- Is this same as KAFKA-6047 ? > StreamsException is thrown after the

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

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205329#comment-16205329 ] Ted Yu commented on KAFKA-6024: --- Thanks, Siva. > Consider moving validation in KafkaConsumer ahead of call

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

[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Issue Type: Test (was: Improvement) > Reduce dependency on mock in connector tests >

[jira] [Updated] (KAFKA-5916) Upgrade rocksdb dependency to 5.8

[ https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5916: -- Summary: Upgrade rocksdb dependency to 5.8 (was: Upgrade rocksdb dependency to 5.7.3) > Upgrade rocksdb

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

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16193918#comment-16193918 ] Ted Yu edited comment on KAFKA-5973 at 10/5/17 11:38 PM: - bq. which to kill the

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

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16193918#comment-16193918 ] Ted Yu commented on KAFKA-5973: --- bq. which to kill itself, which to kill the whole process In description,

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

[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 10/13/17 3:53 PM: - Patch looks good. was

[jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16159614#comment-16159614 ] Ted Yu commented on KAFKA-5505: --- bq. source-connector out-of-the-box that can copy from a relational

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160002#comment-16160002 ] Ted Yu commented on KAFKA-5716: --- {code} + * will be written before after the return of from the call to

[jira] [Commented] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException

[ https://issues.apache.org/jira/browse/KAFKA-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160208#comment-16160208 ] Ted Yu commented on KAFKA-5833: --- Call to Thread.interrupted() which is no-op should be checked in the

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions sometimes hangs

[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Summary: TransactionsTest#testBasicTransactions sometimes hangs (was: TransactionsTest#testBasicTransactions

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Description: While testing 0.11.0.1 RC0 , I found TransactionsTest hanging. Here is part of the stack trace:

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Description: While testing 0.11.0.1 RC0 , I found Here is part of the stack trace: {code} "Test worker" #20

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Attachment: 5840.stack > TransactionsTest#testBasicTransactions hangs >

[jira] [Created] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

Ted Yu created KAFKA-5840: - Summary: TransactionsTest#testBasicTransactions hangs Key: KAFKA-5840 URL: https://issues.apache.org/jira/browse/KAFKA-5840 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

Ted Yu created KAFKA-5842: - Summary: QueryableStateIntegrationTest may fail with JDK 7 Key: KAFKA-5842 URL: https://issues.apache.org/jira/browse/KAFKA-5842 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157155#comment-16157155 ] Ted Yu commented on KAFKA-5855: --- Is the behavior the same for 0.11.0.0 ? Thanks > records-lag is always

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

Ted Yu created KAFKA-5846: - Summary: Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified Key: KAFKA-5846 URL: https://issues.apache.org/jira/browse/KAFKA-5846

[jira] [Updated] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5657: -- Attachment: 5657.v1.txt Is this something close to what you look for ? > Connect REST API should include the

[jira] [Commented] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157887#comment-16157887 ] Ted Yu commented on KAFKA-5657: --- [~rhauch]: Can you take a look ? > Connect REST API should include the

[jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157991#comment-16157991 ] Ted Yu commented on KAFKA-5857: --- bq. After step 5 You listed 4 steps. Did you mean 'after step 4' ? >

[jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16157992#comment-16157992 ] Ted Yu commented on KAFKA-5857: --- Did you manage to get jmap heap dump before the OOME ? > Excessive heap

[jira] [Updated] (KAFKA-5968) Remove all broker metrics during shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5968: -- Attachment: 5968.v1.txt > Remove all broker metrics during shutdown > -

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

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181184#comment-16181184 ] Ted Yu commented on KAFKA-5973: --- [~tcrayford-heroku] [~theduderog]: What do you think of the PR ? >

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

[ https://issues.apache.org/jira/browse/KAFKA-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184644#comment-16184644 ] Ted Yu commented on KAFKA-5967: --- Once you send out pull request, a committer would assign to you. >

[jira] [Created] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE

Ted Yu created KAFKA-5988: - Summary: Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE Key: KAFKA-5988 URL: https://issues.apache.org/jira/browse/KAFKA-5988 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5998: -- Attachment: 5998.v1.txt {code} Files.move(source, target, StandardCopyOption.REPLACE_EXISTING);

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5998: -- Attachment: 5998.v2.txt Patch v2 enables the log when renaming to secondary fails. > /.checkpoint.tmp Not

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187353#comment-16187353 ] Ted Yu edited comment on KAFKA-5998 at 10/1/17 3:10 PM: Patch v1 has been

[jira] [Commented] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE

[ https://issues.apache.org/jira/browse/KAFKA-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187645#comment-16187645 ] Ted Yu commented on KAFKA-5988: --- Please go ahead. > Consider removing

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16187353#comment-16187353 ] Ted Yu commented on KAFKA-5998: --- Patch v1 has been attached. If the .tmp file cannot be renamed, the

[jira] [Commented] (KAFKA-6000) streams 0.10.2.1 - kafka 0.11.0.1 state restore not working

[ https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16189947#comment-16189947 ] Ted Yu commented on KAFKA-6000: --- I wonder if the following had something to do with the problem: {code}

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

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179702#comment-16179702 ] Ted Yu commented on KAFKA-5973: --- Interesting. Looks like the following class is not used:

[jira] [Created] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

Ted Yu created KAFKA-5967: - Summary: Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries() Key: KAFKA-5967 URL: https://issues.apache.org/jira/browse/KAFKA-5967

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

[ https://issues.apache.org/jira/browse/KAFKA-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182694#comment-16182694 ] Ted Yu commented on KAFKA-5973: --- [~damianguy] [~guozhang]: Can you take a look ? Thanks >

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

Ted Yu created KAFKA-5802: - Summary: ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get() Key: KAFKA-5802 URL: https://issues.apache.org/jira/browse/KAFKA-5802

[jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149786#comment-16149786 ] Ted Yu commented on KAFKA-5818: --- Looking at StreamThread, in the call chain run() -> runLoop() -> runOnce()

[jira] [Created] (KAFKA-5821) Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls

Ted Yu created KAFKA-5821: - Summary: Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls Key: KAFKA-5821 URL: https://issues.apache.org/jira/browse/KAFKA-5821 Project: Kafka

[jira] [Created] (KAFKA-5820) Remove unneeded synchronized keyword in StreamThread

Ted Yu created KAFKA-5820: - Summary: Remove unneeded synchronized keyword in StreamThread Key: KAFKA-5820 URL: https://issues.apache.org/jira/browse/KAFKA-5820 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16149980#comment-16149980 ] Ted Yu commented on KAFKA-5818: --- {code} public synchronized boolean isRunningAndNotRebalancing() {

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

[ 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: ) > Reduce dependency on mock in connector tests >

[jira] [Updated] (KAFKA-5911) Avoid creation of extra Map for futures in KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5911: -- Labels: client (was: ) > Avoid creation of extra Map for futures in KafkaAdminClient >

[jira] [Resolved] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE

[ https://issues.apache.org/jira/browse/KAFKA-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5988. --- Resolution: Won't Fix > Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE >

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

[ 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-6049) Kafka Streams: Add Cogroup in the DSL

[ https://issues.apache.org/jira/browse/KAFKA-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199645#comment-16199645 ] Ted Yu commented on KAFKA-6049: --- bq. ValueGetters keep calling ValueGetters until Is there typo above ? >

[jira] [Commented] (KAFKA-6046) DeleteRecordsRequest to a non-leader

[ https://issues.apache.org/jira/browse/KAFKA-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16202003#comment-16202003 ] Ted Yu commented on KAFKA-6046: --- Can someone assign this to me ? > DeleteRecordsRequest to a non-leader >

[jira] [Commented] (KAFKA-6085) Streams rebalancing may cause a first batch of fetched records to be dropped

[ https://issues.apache.org/jira/browse/KAFKA-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16210527#comment-16210527 ] Ted Yu commented on KAFKA-6085: --- {code} final ConsumerRecords records =

[jira] [Commented] (KAFKA-5027) Kafka Controller Redesign

[ https://issues.apache.org/jira/browse/KAFKA-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209377#comment-16209377 ] Ted Yu commented on KAFKA-5027: --- If there is dependency among the 'Use ZookeeperClient in' tasks, it would

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

[ https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216171#comment-16216171 ] Ted Yu commented on KAFKA-6074: --- In ReplicationUtils#propagateIsrChanges() (called by

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

Ted Yu created KAFKA-6109: - Summary: ResetIntegrationTest may fail due to IllegalArgumentException Key: KAFKA-6109 URL: https://issues.apache.org/jira/browse/KAFKA-6109 Project: Kafka Issue Type:

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-6074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216193#comment-16216193 ] Ted Yu commented on KAFKA-6074: --- {code} val zkPath = new ZkPath(zkClientWrap) {code} Before I pull ZkPath

[jira] [Commented] (KAFKA-6086) KIP-210 Provide for custom error handling when Kafka Streams fails to produce

[ https://issues.apache.org/jira/browse/KAFKA-6086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16210291#comment-16210291 ] Ted Yu commented on KAFKA-6086: --- Normally there is no need to put the KIP number in the subject of JIRA. >

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

[ 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

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

[ 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] [Created] (KAFKA-6215) KafkaStreamsTest fails in trunk

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265861#comment-16265861 ] Ted Yu commented on KAFKA-6168: --- bq. it might be worth considering having each instance precompute and cache

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

[ 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

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273872#comment-16273872 ] Ted Yu edited comment on KAFKA-6288 at 12/1/17 3:29 AM: How does the patch look

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

[ 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-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

[ 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-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ 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

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

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:

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

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

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

[ 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] [Created] (KAFKA-6384) TransactionsTest#testFencingOnSendOffsets sometimes fails with ProducerFencedException

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:

  1   2   3   4   5   >