[jira] [Created] (KAFKA-9863) update the deprecated --zookeeper option in the documentation into --bootstrap-server

Luke Chen created KAFKA-9863: Summary: update the deprecated --zookeeper option in the documentation into --bootstrap-server Key: KAFKA-9863 URL: https://issues.apache.org/jira/browse/KAFKA-9863 Project:

[jira] [Commented] (KAFKA-9863) update the deprecated --zookeeper option in the documentation into --bootstrap-server

[ https://issues.apache.org/jira/browse/KAFKA-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085487#comment-17085487 ] Luke Chen commented on KAFKA-9863: -- PR: https://github.com/apache/kafka/pull/8482 > update the

[jira] [Commented] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067347#comment-17067347 ] Luke Chen commented on KAFKA-9617: -- I can take this if no one else is looking at this issue. Thanks. >

[jira] [Comment Edited] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067347#comment-17067347 ] Luke Chen edited comment on KAFKA-9617 at 3/26/20, 4:27 AM: I can take this

[jira] [Comment Edited] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068518#comment-17068518 ] Luke Chen edited comment on KAFKA-9773 at 3/27/20, 10:21 AM: - Please use

[jira] [Commented] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068518#comment-17068518 ] Luke Chen commented on KAFKA-9773: -- Please use kafka-config.sh --alter instead. Ex:

[jira] [Commented] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068530#comment-17068530 ] Luke Chen commented on KAFKA-9773: -- Meanwhile, I'll work on this issue. > Option combination

[jira] [Commented] (KAFKA-9785) use kafka-topics.sh can't --alter replication-factor???

[ https://issues.apache.org/jira/browse/KAFKA-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070759#comment-17070759 ] Luke Chen commented on KAFKA-9785: -- [~startjava], please check below link for how to increasing

[jira] [Commented] (KAFKA-9785) use kafka-topics.sh can't --alter replication-factor???

[ https://issues.apache.org/jira/browse/KAFKA-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070761#comment-17070761 ] Luke Chen commented on KAFKA-9785: -- 好的! Will do! > use kafka-topics.sh can't --alter

[jira] [Commented] (KAFKA-9785) use kafka-topics.sh can't --alter replication-factor???

[ https://issues.apache.org/jira/browse/KAFKA-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070741#comment-17070741 ] Luke Chen commented on KAFKA-9785: -- I will update the doc. Thanks. > use kafka-topics.sh can't --alter

[jira] [Comment Edited] (KAFKA-9979) The "--zookeeper" option can't be used with bin/kafka-configs.sh . The document should be updated

[ https://issues.apache.org/jira/browse/KAFKA-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105034#comment-17105034 ] Luke Chen edited comment on KAFKA-9979 at 5/12/20, 3:44 AM: Hi [~adally] ,

[jira] [Commented] (KAFKA-9979) The "--zookeeper" option can't be used with bin/kafka-configs.sh . The document should be updated

[ https://issues.apache.org/jira/browse/KAFKA-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105034#comment-17105034 ] Luke Chen commented on KAFKA-9979: -- Hi [~adally] , this issue has been fixed. Please check here:

[jira] [Commented] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103768#comment-17103768 ] Luke Chen commented on KAFKA-9617: -- No, I haven't started to work on this. Go ahead to take it. Thanks.

[jira] [Assigned] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-9974: Assignee: Luke Chen > Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

[jira] [Updated] (KAFKA-10004) using kafka-configs.sh --describe for brokers will have error when querying default broker

[ https://issues.apache.org/jira/browse/KAFKA-10004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10004: -- Description: When running {code:java} bin/kafka-configs.sh --describe --bootstrap-server

[jira] [Created] (KAFKA-10004) using kafka-configs.sh --describe for brokers will have error when querying default broker

Luke Chen created KAFKA-10004: - Summary: using kafka-configs.sh --describe for brokers will have error when querying default broker Key: KAFKA-10004 URL: https://issues.apache.org/jira/browse/KAFKA-10004

[jira] [Assigned] (KAFKA-10006) Streams should not attempt to create internal topics that may exist

[ https://issues.apache.org/jira/browse/KAFKA-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10006: - Assignee: Luke Chen > Streams should not attempt to create internal topics that may exist >

[jira] [Assigned] (KAFKA-10459) Document IQ APIs where order does not hold between stores

[ https://issues.apache.org/jira/browse/KAFKA-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10459: - Assignee: Luke Chen > Document IQ APIs where order does not hold between stores >

[jira] [Commented] (KAFKA-10450) console-producer throws Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender) java.lang.IllegalStateException: There are n

[ https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188235#comment-17188235 ] Luke Chen commented on KAFKA-10450: --- I think this behavior is expected. The *address already in use*

[jira] [Comment Edited] (KAFKA-10450) console-producer throws Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender) java.lang.IllegalStateException: There

[ https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188235#comment-17188235 ] Luke Chen edited comment on KAFKA-10450 at 9/1/20, 7:54 AM: I think this

[jira] [Comment Edited] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"

[ https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192037#comment-17192037 ] Luke Chen edited comment on KAFKA-10467 at 9/8/20, 8:34 AM: [~swayamraina] ,

[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"

[ https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192037#comment-17192037 ] Luke Chen commented on KAFKA-10467: --- [~swayamraina] , your feed the wrong parameter into send method.

[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"

[ https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193292#comment-17193292 ] Luke Chen commented on KAFKA-10467: --- > Any idea what causes this? -> Sorry, I cannot reproduce it in

[jira] [Created] (KAFKA-10482) Fix flaky testDynamicListenerConnectionCreationRateQuota

Luke Chen created KAFKA-10482: - Summary: Fix flaky testDynamicListenerConnectionCreationRateQuota Key: KAFKA-10482 URL: https://issues.apache.org/jira/browse/KAFKA-10482 Project: Kafka Issue

[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217456#comment-17217456 ] Luke Chen commented on KAFKA-10043: --- Thanks, [~chia7712] ! [~tigertan], I can take over if you don't

[jira] [Commented] (KAFKA-10425) Documentation switches to a random page on clicking the left navigation bar hide/expand button

[ https://issues.apache.org/jira/browse/KAFKA-10425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183034#comment-17183034 ] Luke Chen commented on KAFKA-10425: --- I'm having the same issue, too.   > Documentation switches to a

[jira] [Commented] (KAFKA-10482) Fix flaky testDynamicListenerConnectionCreationRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199878#comment-17199878 ] Luke Chen commented on KAFKA-10482: ---

[jira] [Commented] (KAFKA-10482) Fix flaky testDynamicListenerConnectionCreationRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198153#comment-17198153 ] Luke Chen commented on KAFKA-10482: ---

[jira] [Commented] (KAFKA-10495) Fix spelling mistake

[ https://issues.apache.org/jira/browse/KAFKA-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197699#comment-17197699 ] Luke Chen commented on KAFKA-10495: --- *if and only if* (shortened as *iff*) , fyi

[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119491#comment-17119491 ] Luke Chen commented on KAFKA-10043: --- [~tigertan], you should mention other users to review your PR.

[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119410#comment-17119410 ] Luke Chen commented on KAFKA-10043: --- Yes, you should add tests to it, and then send for review. >

[jira] [Assigned] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10038: - Assignee: Luke Chen > ConsumerPerformance.scala supports the setting of client.id >

[jira] [Commented] (KAFKA-10043) Some parameters will be overwritten which was configured in consumer.config where running "ConsumerPerformance.scala"

[ https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119210#comment-17119210 ] Luke Chen commented on KAFKA-10043: --- hi [~tigertan], are you working on this issue? if no, I can take

[jira] [Updated] (KAFKA-10081) Execution failed for task ':clients:spotbugsMain' in recent build

[ https://issues.apache.org/jira/browse/KAFKA-10081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10081: -- Description: : Task failed with an exception. --- * What went wrong: Execution failed for

[jira] [Created] (KAFKA-10081) Execution failed for task ':clients:spotbugsMain' in recent build

Luke Chen created KAFKA-10081: - Summary: Execution failed for task ':clients:spotbugsMain' in recent build Key: KAFKA-10081 URL: https://issues.apache.org/jira/browse/KAFKA-10081 Project: Kafka

[jira] [Created] (KAFKA-10082) fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment

Luke Chen created KAFKA-10082: - Summary: fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment Key: KAFKA-10082 URL: https://issues.apache.org/jira/browse/KAFKA-10082 Project:

[jira] [Created] (KAFKA-10083) fix failed testReassignmentWithRandomSubscriptionsAndChanges

Luke Chen created KAFKA-10083: - Summary: fix failed testReassignmentWithRandomSubscriptionsAndChanges Key: KAFKA-10083 URL: https://issues.apache.org/jira/browse/KAFKA-10083 Project: Kafka

[jira] [Updated] (KAFKA-10083) fix failed testReassignmentWithRandomSubscriptionsAndChanges

[ https://issues.apache.org/jira/browse/KAFKA-10083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10083: -- Description: [https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/]   h3. Error Message

[jira] [Updated] (KAFKA-10083) fix failed testReassignmentWithRandomSubscriptionsAndChanges

[ https://issues.apache.org/jira/browse/KAFKA-10083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10083: -- Description: [https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/] It can also locally

[jira] [Updated] (KAFKA-10082) fix failed kafka.api.PlaintextConsumerTest.testMultiConsumerStickyAssignment

[ https://issues.apache.org/jira/browse/KAFKA-10082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10082: -- Reviewer: Sophie Blee-Goldman > fix failed

[jira] [Commented] (KAFKA-10482) Fix flaky testDynamicListenerConnectionCreationRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199280#comment-17199280 ] Luke Chen commented on KAFKA-10482: ---

[jira] [Assigned] (KAFKA-10645) Forwarding a record from a punctuator sometimes it results in a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10645: - Assignee: Luke Chen > Forwarding a record from a punctuator sometimes it results in a >

[jira] [Commented] (KAFKA-10645) Forwarding a record from a punctuator sometimes it results in a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222051#comment-17222051 ] Luke Chen commented on KAFKA-10645: --- I found the root cause. It's because when user using

[jira] [Assigned] (KAFKA-10645) Forwarding a record from a punctuator sometimes it results in a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10645: - Assignee: Matthias J. Sax (was: Luke Chen) > Forwarding a record from a punctuator sometimes

[jira] [Commented] (KAFKA-10645) Forwarding a record from a punctuator sometimes it results in a NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222054#comment-17222054 ] Luke Chen commented on KAFKA-10645: --- Assign to [~mjsax]  since the PR:

[jira] [Assigned] (KAFKA-10628) Follow-up: Remove all unnecessary dummy TopologyTestDriver configs

[ https://issues.apache.org/jira/browse/KAFKA-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10628: - Assignee: Luke Chen > Follow-up: Remove all unnecessary dummy TopologyTestDriver configs >

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162567#comment-17162567 ] Luke Chen commented on KAFKA-8098: -- Failed at different places  

[jira] [Reopened] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-8098: -- > Flaky Test AdminClientIntegrationTest#testConsumerGroups >

[jira] [Assigned] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-8098: Assignee: Luke Chen (was: huxihx) > Flaky Test AdminClientIntegrationTest#testConsumerGroups >

[jira] [Commented] (KAFKA-10323) NullPointerException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-10323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167660#comment-17167660 ] Luke Chen commented on KAFKA-10323: --- [~kkonstantine] , do you think this is the expected behavior? Or

[jira] [Assigned] (KAFKA-10323) NullPointerException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-10323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10323: - Assignee: Luke Chen > NullPointerException during rebalance >

[jira] [Commented] (KAFKA-10266) Fix connector configs in docs to mention the correct default value inherited from worker configs

[ https://issues.apache.org/jira/browse/KAFKA-10266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167681#comment-17167681 ] Luke Chen commented on KAFKA-10266: --- [PR:

[jira] [Assigned] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10340: - Assignee: Luke Chen > Source connectors should report error when trying to produce records to

[jira] [Assigned] (KAFKA-10351) Add missing tests for IOExceptions for GlobalStateManagerImpl

[ https://issues.apache.org/jira/browse/KAFKA-10351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10351: - Assignee: Luke Chen > Add missing tests for IOExceptions for GlobalStateManagerImpl >

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171250#comment-17171250 ] Luke Chen commented on KAFKA-8098: --

[jira] [Assigned] (KAFKA-10392) kafka-producer-perf-test.sh includes messages successfully delivered when acks=-1

[ https://issues.apache.org/jira/browse/KAFKA-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10392: - Assignee: Luke Chen > kafka-producer-perf-test.sh includes messages successfully delivered

[jira] [Commented] (KAFKA-8362) LogCleaner gets stuck after partition move between log directories

[ https://issues.apache.org/jira/browse/KAFKA-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176257#comment-17176257 ] Luke Chen commented on KAFKA-8362: -- Currently, we'll append a tombstone record into the source(old)

[jira] [Assigned] (KAFKA-10390) kafka-server-stop lookup is not specific enough and may kill other processes

[ https://issues.apache.org/jira/browse/KAFKA-10390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10390: - Assignee: Luke Chen > kafka-server-stop lookup is not specific enough and may kill other

[jira] [Commented] (KAFKA-8362) LogCleaner gets stuck after partition move between log directories

[ https://issues.apache.org/jira/browse/KAFKA-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176934#comment-17176934 ] Luke Chen commented on KAFKA-8362: -- OK, after further investigation today, I found I was wrong. The root

[jira] [Commented] (KAFKA-10390) kafka-server-stop lookup is not specific enough and may kill other processes

[ https://issues.apache.org/jira/browse/KAFKA-10390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177446#comment-17177446 ] Luke Chen commented on KAFKA-10390: --- Remove the ignore case option is good to me since our entry point

[jira] [Commented] (KAFKA-10398) Intra-broker disk move failed with onPartitionFenced()

[ https://issues.apache.org/jira/browse/KAFKA-10398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177440#comment-17177440 ] Luke Chen commented on KAFKA-10398: --- I'm not aware of this issue, sorry > Intra-broker disk move

[jira] [Commented] (KAFKA-8362) LogCleaner gets stuck after partition move between log directories

[ https://issues.apache.org/jira/browse/KAFKA-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177416#comment-17177416 ] Luke Chen commented on KAFKA-8362: -- Sorry, I linked to the wrong Jira id yesterday. You can check the

[jira] [Assigned] (KAFKA-10378) issue when create producer using java

[ https://issues.apache.org/jira/browse/KAFKA-10378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10378: - Assignee: Luke Chen > issue when create producer using java >

[jira] [Assigned] (KAFKA-8362) LogCleaner gets stuck after partition move between log directories

[ https://issues.apache.org/jira/browse/KAFKA-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-8362: Assignee: Luke Chen > LogCleaner gets stuck after partition move between log directories >

[jira] [Comment Edited] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174105#comment-17174105 ] Luke Chen edited comment on KAFKA-10340 at 8/10/20, 6:45 AM: - After

[jira] [Commented] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174105#comment-17174105 ] Luke Chen commented on KAFKA-10340: --- Will improve the logging in this area. Proposed to add 3 logs:

[jira] [Comment Edited] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174105#comment-17174105 ] Luke Chen edited comment on KAFKA-10340 at 8/10/20, 6:38 AM: - After

[jira] [Comment Edited] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174105#comment-17174105 ] Luke Chen edited comment on KAFKA-10340 at 8/10/20, 6:40 AM: - After

[jira] [Comment Edited] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174105#comment-17174105 ] Luke Chen edited comment on KAFKA-10340 at 8/10/20, 6:38 AM: - Will improve

[jira] [Commented] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

[ https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174125#comment-17174125 ] Luke Chen commented on KAFKA-10038: --- This might need a KIP. Working on that. >

[jira] [Assigned] (KAFKA-10220) NPE when describing resources

[ https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10220: - Assignee: Luke Chen > NPE when describing resources > - > >

[jira] [Created] (KAFKA-10255) Fix flaky testOneWayReplicationWithAutorOffsetSync1 test

Luke Chen created KAFKA-10255: - Summary: Fix flaky testOneWayReplicationWithAutorOffsetSync1 test Key: KAFKA-10255 URL: https://issues.apache.org/jira/browse/KAFKA-10255 Project: Kafka Issue

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157280#comment-17157280 ] Luke Chen commented on KAFKA-8264: --

[jira] [Assigned] (KAFKA-10266) Fix connector configs in docs to mention the correct default value inherited from worker configs

[ https://issues.apache.org/jira/browse/KAFKA-10266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10266: - Assignee: Luke Chen > Fix connector configs in docs to mention the correct default value

[jira] [Commented] (KAFKA-10220) NPE when describing resources

[ https://issues.apache.org/jira/browse/KAFKA-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149206#comment-17149206 ] Luke Chen commented on KAFKA-10220: --- [~tombentley], I'll submit a PR for your review later. Thanks. >

[jira] [Commented] (KAFKA-10176) kafka-topics command requires --zookeeper for --alter --topic --config

[ https://issues.apache.org/jira/browse/KAFKA-10176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138037#comment-17138037 ] Luke Chen commented on KAFKA-10176: --- hi [~psmolinski] , I think it is the issue in confluent doc. In

[jira] [Assigned] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-8264: Assignee: Luke Chen > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[jira] [Assigned] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-8460: Assignee: Luke Chen > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142596#comment-17142596 ] Luke Chen commented on KAFKA-9509: --

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140914#comment-17140914 ] Luke Chen commented on KAFKA-9509: -- PR: [https://github.com/apache/kafka/pull/8894]   > Fix flaky test

[jira] [Commented] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140162#comment-17140162 ] Luke Chen commented on KAFKA-9974: -- I don't have thought on fixing the errors. See if anyone wants to

[jira] [Assigned] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-9974: Assignee: (was: Luke Chen) > Flaky Test

[jira] [Assigned] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-9509: Assignee: Luke Chen (was: Sanjana Kaundinya) > Fix flaky test

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139217#comment-17139217 ] Luke Chen commented on KAFKA-9509: --

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139218#comment-17139218 ] Luke Chen commented on KAFKA-9509: -- I take it over since it failed quite often recently, and also failed

[jira] [Created] (KAFKA-10118) Improve stickiness verification for AbstractStickyAssignorTest

Luke Chen created KAFKA-10118: - Summary: Improve stickiness verification for AbstractStickyAssignorTest Key: KAFKA-10118 URL: https://issues.apache.org/jira/browse/KAFKA-10118 Project: Kafka

[jira] [Updated] (KAFKA-10118) Improve stickiness verification for AbstractStickyAssignorTest

[ https://issues.apache.org/jira/browse/KAFKA-10118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10118: -- Description: In KAFKA-9987 , we implemented an optimized sticky partition assignor algorithm (i.e.

[jira] [Updated] (KAFKA-10118) Improve stickiness verification for AbstractStickyAssignorTest

[ https://issues.apache.org/jira/browse/KAFKA-10118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10118: -- Description: In KAFKA-9987 , we implemented an optimized sticky partition assignor algorithm (i.e.

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163397#comment-17163397 ] Luke Chen commented on KAFKA-8098: -- In the test, we first test removing 1 member from group, and then

[jira] [Assigned] (KAFKA-10315) Consider to throw exception for failed fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10315: - Assignee: Luke Chen > Consider to throw exception for failed fetch requests >

[jira] [Commented] (KAFKA-10315) Consider to throw exception for failed fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166146#comment-17166146 ] Luke Chen commented on KAFKA-10315: --- [~mjsax], Thanks for reminding. I'll wait and see what other team

[jira] [Assigned] (KAFKA-10401) GroupMetadataManager ignores current_state_timestamp field for GROUP_METADATA_VALUE_SCHEMA_V3

[ https://issues.apache.org/jira/browse/KAFKA-10401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10401: - Assignee: Luke Chen > GroupMetadataManager ignores current_state_timestamp field for >

[jira] [Commented] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260199#comment-17260199 ] Luke Chen commented on KAFKA-8460: -- Still seeing the test failure. Working on it! > Flaky Test

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-8460: -- > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition >

[jira] [Commented] (KAFKA-10776) JMX metric RequestsPerSec requires API version to access

[ https://issues.apache.org/jira/browse/KAFKA-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240442#comment-17240442 ] Luke Chen commented on KAFKA-10776: --- [~ijuma], you're right! This is actually a documentation miss,

[jira] [Assigned] (KAFKA-10776) JMX metric RequestsPerSec requires API version to access

[ https://issues.apache.org/jira/browse/KAFKA-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10776: - Assignee: Luke Chen > JMX metric RequestsPerSec requires API version to access >

[jira] [Assigned] (KAFKA-10665) Flaky Test StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization = all]

[ https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-10665: - Assignee: Luke Chen > Flaky Test >

[jira] [Commented] (KAFKA-10665) Flaky Test StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization = all]

[ https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242063#comment-17242063 ] Luke Chen commented on KAFKA-10665: ---

[jira] [Commented] (KAFKA-10665) Flaky Test StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization = all]

[ https://issues.apache.org/jira/browse/KAFKA-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242062#comment-17242062 ] Luke Chen commented on KAFKA-10665: ---

[jira] [Updated] (KAFKA-10754) Fix flaky shouldShutdownSingleThreadApplication test

[ https://issues.apache.org/jira/browse/KAFKA-10754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-10754: -- Fix Version/s: 2.8.0 > Fix flaky shouldShutdownSingleThreadApplication test >

  1   2   3   4   5   6   7   8   9   10   >