[jira] [Resolved] (KAFKA-14371) quorum-state file contains empty/unused clusterId field

2023-02-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14371. --- Fix Version/s: 3.5.0 Resolution: Fixed > quorum-state file contains empty/unused clusterId fi

[jira] [Updated] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

2023-02-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-13771: -- Fix Version/s: 3.5.0 > Support to explicitly delete delegationTokens that have expired but have not >

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

2023-02-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694387#comment-17694387 ] Luke Chen commented on KAFKA-13771: --- [~RivenSun] , you can update it by yourselves. Th

[jira] [Updated] (KAFKA-14295) FetchMessageConversionsPerSec meter not recorded

2023-02-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14295: -- Fix Version/s: 3.4.1 > FetchMessageConversionsPerSec meter not recorded >

[jira] [Resolved] (KAFKA-14743) MessageConversionsTimeMs for fetch request metric is not updated

2023-02-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14743. --- Fix Version/s: 3.5.0 3.4.1 Resolution: Fixed > MessageConversionsTimeMs fo

[jira] [Updated] (KAFKA-14752) improve kafka examples under examples package

2023-02-24 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14752: -- Description: Kafka provided some examples under "examples" package. Currently we provided * java-prod

[jira] [Commented] (KAFKA-14757) Kafka Cooperative Sticky Assignor results in significant duplicate consumption

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693057#comment-17693057 ] Luke Chen commented on KAFKA-14757: --- Oh, wait, you didn't enable `enable.auto.commit`.

[jira] [Commented] (KAFKA-14757) Kafka Cooperative Sticky Assignor results in significant duplicate consumption

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693049#comment-17693049 ] Luke Chen commented on KAFKA-14757: --- The reason should be KAFKA-14224. That's a known

[jira] [Updated] (KAFKA-14752) improve kafka examples under examples package

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14752: -- Description: A good example in a project is really important. This is usually the entry point when ne

[jira] [Updated] (KAFKA-14752) improve kafka examples under examples package

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14752: -- Description: A good example in a project is really important. This is usually the entry point when ne

[jira] [Updated] (KAFKA-14752) improve kafka examples under examples package

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14752: -- Description: A good example in a open source project is really important. This is usually the entry p

[jira] [Created] (KAFKA-14756) improve exactly-once-demo example and ExactlyOnceMessageProcessor

2023-02-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14756: - Summary: improve exactly-once-demo example and ExactlyOnceMessageProcessor Key: KAFKA-14756 URL: https://issues.apache.org/jira/browse/KAFKA-14756 Project: Kafka

[jira] [Created] (KAFKA-14755) improve java-producer-consumer-demo

2023-02-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14755: - Summary: improve java-producer-consumer-demo Key: KAFKA-14755 URL: https://issues.apache.org/jira/browse/KAFKA-14755 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-14754) improve consumer under example package

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693001#comment-17693001 ] Luke Chen commented on KAFKA-14754: --- Welcome to contribute to them [~pnee]    > impr

[jira] [Created] (KAFKA-14753) improve producer under example package

2023-02-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14753: - Summary: improve producer under example package Key: KAFKA-14753 URL: https://issues.apache.org/jira/browse/KAFKA-14753 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14754) improve consumer under example package

2023-02-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14754: - Summary: improve consumer under example package Key: KAFKA-14754 URL: https://issues.apache.org/jira/browse/KAFKA-14754 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-14752) improve kafka examples under examples package

2023-02-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14752: - Summary: improve kafka examples under examples package Key: KAFKA-14752 URL: https://issues.apache.org/jira/browse/KAFKA-14752 Project: Kafka Issue Type: Improveme

[jira] [Updated] (KAFKA-14743) MessageConversionsTimeMs for fetch request metric is not updated

2023-02-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14743: -- Summary: MessageConversionsTimeMs for fetch request metric is not updated (was: MessageConversionsTim

[jira] [Created] (KAFKA-14743) MessageConversionsTimeMs metric is not updated

2023-02-23 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14743: - Summary: MessageConversionsTimeMs metric is not updated Key: KAFKA-14743 URL: https://issues.apache.org/jira/browse/KAFKA-14743 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-14495) Improve the RemoteIndexCacheTest

2023-02-22 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14495. --- Fix Version/s: 3.5.0 Resolution: Fixed > Improve the RemoteIndexCacheTest > -

[jira] [Commented] (KAFKA-14739) Kafka consumer reading messages out of order after a rebalance

2023-02-22 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692452#comment-17692452 ] Luke Chen commented on KAFKA-14739: --- [~colinshaw] , Have you tried to run with the lat

[jira] [Commented] (KAFKA-14304) ZooKeeper to KRaft Migration

2023-02-22 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692106#comment-17692106 ] Luke Chen commented on KAFKA-14304: --- [~mumrah] , also, the fixed version of this epic

[jira] [Commented] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690218#comment-17690218 ] Luke Chen commented on KAFKA-14729: --- The change makes sense to me. But I'm more intere

[jira] [Commented] (KAFKA-14698) Received request api key LEADER_AND_ISR which is not enabled

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689733#comment-17689733 ] Luke Chen commented on KAFKA-14698: --- [~akhileshchg] , are you still up to this issue?

[jira] [Commented] (KAFKA-14304) ZooKeeper to KRaft Migration

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689676#comment-17689676 ] Luke Chen commented on KAFKA-14304: --- [~mumrah] , I'd like to contribute to this featur

[jira] [Assigned] (KAFKA-14447) Controlled shutdown for ZK brokers during migration

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14447: - Assignee: Luke Chen > Controlled shutdown for ZK brokers during migration > ---

[jira] [Resolved] (KAFKA-14621) Don't startup in migration mode if an authorizer is enabled

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14621. --- Fix Version/s: 3.4.0 Resolution: Done Close this since this is completed in kafka v3.4.0  

[jira] [Commented] (KAFKA-14493) Zk to KRaft migration state machine in KRaft controller

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689647#comment-17689647 ] Luke Chen commented on KAFKA-14493: --- [~akhileshchg] [~mumrah] , this is completed in v

[jira] [Commented] (KAFKA-14458) RPC Handler to ZkBrokers from KRaft Controller

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689643#comment-17689643 ] Luke Chen commented on KAFKA-14458: --- [~akhileshchg] [~mumrah] , looks like this task i

[jira] [Commented] (KAFKA-14446) API forwarding support in ZkBrokers

2023-02-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689606#comment-17689606 ] Luke Chen commented on KAFKA-14446: --- [~akhileshchg] [~mumrah] , I checked the PR and I

[jira] [Resolved] (KAFKA-14708) Remove kafka.examples.Consumer dependancy on ShutdownableThread

2023-02-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14708. --- Fix Version/s: 3.5.0 Resolution: Fixed > Remove kafka.examples.Consumer dependancy on Shutdow

[jira] [Commented] (KAFKA-12473) Make the "cooperative-sticky, range" as the default assignor

2023-02-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689070#comment-17689070 ] Luke Chen commented on KAFKA-12473: --- Removed the fixed version value until we have som

[jira] [Updated] (KAFKA-12473) Make the "cooperative-sticky, range" as the default assignor

2023-02-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-12473: -- Fix Version/s: (was: 3.5.0) > Make the "cooperative-sticky, range" as the default assignor > -

[jira] [Commented] (KAFKA-14704) Follower should truncate before incrementing high watermark

2023-02-10 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686996#comment-17686996 ] Luke Chen commented on KAFKA-14704: --- No worries! Nice catch!   > Follower should tru

[jira] [Commented] (KAFKA-14704) Follower should truncate before incrementing high watermark

2023-02-10 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686986#comment-17686986 ] Luke Chen commented on KAFKA-14704: --- [~dajac] , could you add some bug description? Th

[jira] [Commented] (KAFKA-14692) Issues in Zookeeper to KRaft migration docs

2023-02-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686404#comment-17686404 ] Luke Chen commented on KAFKA-14692: --- [~mumrah] , I think we should filter out (isMigra

[jira] [Commented] (KAFKA-14692) Issues in Zookeeper to KRaft migration docs

2023-02-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686352#comment-17686352 ] Luke Chen commented on KAFKA-14692: --- I was wrong about the workaround. It just let the

[jira] [Commented] (KAFKA-14692) Issues in Zookeeper to KRaft migration docs

2023-02-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686281#comment-17686281 ] Luke Chen commented on KAFKA-14692: --- For (4) the error: {code:java} org.apache.kafka.c

[jira] [Resolved] (KAFKA-14695) broker will get LEADER_AND_ISR is not enabled error while ZK migrating to KRaft

2023-02-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14695. --- Resolution: Duplicate > broker will get LEADER_AND_ISR is not enabled error while ZK migrating to >

[jira] [Created] (KAFKA-14695) broker will get LEADER_AND_ISR is not enabled error while ZK migrating to KRaft

2023-02-08 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14695: - Summary: broker will get LEADER_AND_ISR is not enabled error while ZK migrating to KRaft Key: KAFKA-14695 URL: https://issues.apache.org/jira/browse/KAFKA-14695 Project: Ka

[jira] [Updated] (KAFKA-14604) SASL session expiration time will be overflowed when calculation

2023-01-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14604: -- Description: When sasl server of client set a large expiration time, the timeout value might be overf

[jira] [Assigned] (KAFKA-14602) offsetDelta in BatchMetadata is an int but the values are computed as difference of offsets which are longs.

2023-01-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14602: - Assignee: Luke Chen > offsetDelta in BatchMetadata is an int but the values are computed as >

[jira] [Updated] (KAFKA-14604) SASL session expiration time will be overflowed when calculation

2023-01-07 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14604: -- Affects Version/s: (was: 3.3.1) > SASL session expiration time will be overflowed when calculation

[jira] [Updated] (KAFKA-14604) SASL session expiration time will be overflowed when calculation

2023-01-07 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14604: -- Description: When sasl server of client set a large expiration time, the timeout value might be overf

[jira] [Created] (KAFKA-14604) SASL session expiration time will be overflowed when calculation

2023-01-07 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14604: - Summary: SASL session expiration time will be overflowed when calculation Key: KAFKA-14604 URL: https://issues.apache.org/jira/browse/KAFKA-14604 Project: Kafka I

[jira] [Commented] (KAFKA-14564) Upgrade Netty to 4.1.86.Final to fix CVEs

2023-01-04 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654353#comment-17654353 ] Luke Chen commented on KAFKA-14564: --- [~ableegoldman] , do we want to include this into

[jira] [Updated] (KAFKA-14564) Upgrade Netty to 4.1.86.Final to fix CVEs

2023-01-04 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14564: -- Fix Version/s: 3.5.0 > Upgrade Netty to 4.1.86.Final to fix CVEs > ---

[jira] [Updated] (KAFKA-14556) log cleaner throttler start time is wrong when 1st run

2022-12-29 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14556: -- Summary: log cleaner throttler start time is wrong when 1st run (was: log cleaner throttler start tim

[jira] [Assigned] (KAFKA-14556) log cleaner throttler start time is correct

2022-12-29 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14556: - Assignee: Luke Chen > log cleaner throttler start time is correct > ---

[jira] [Created] (KAFKA-14556) log cleaner throttler start time is correct

2022-12-29 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14556: - Summary: log cleaner throttler start time is correct Key: KAFKA-14556 URL: https://issues.apache.org/jira/browse/KAFKA-14556 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-14553) RecordAccumulator hangs in infinite NOP loop

2022-12-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652076#comment-17652076 ] Luke Chen commented on KAFKA-14553: --- [~gviczai] , thanks for reporting the issue. This

[jira] [Resolved] (KAFKA-14553) RecordAccumulator hangs in infinite NOP loop

2022-12-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14553. --- Fix Version/s: 3.4.0 3.3.2 Resolution: Duplicate > RecordAccumulator hangs

[jira] [Updated] (KAFKA-14498) flaky org.apache.kafka.tools.MetadataQuorumCommandTest

2022-12-20 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14498: -- Fix Version/s: 3.5.0 > flaky org.apache.kafka.tools.MetadataQuorumCommandTest > --

[jira] [Created] (KAFKA-14529) fix failed KafkaServerKRaftRegistrationTest

2022-12-18 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14529: - Summary: fix failed KafkaServerKRaftRegistrationTest Key: KAFKA-14529 URL: https://issues.apache.org/jira/browse/KAFKA-14529 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-14498) flaky org.apache.kafka.tools.MetadataQuorumCommandTest

2022-12-16 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14498: - Summary: flaky org.apache.kafka.tools.MetadataQuorumCommandTest Key: KAFKA-14498 URL: https://issues.apache.org/jira/browse/KAFKA-14498 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-14466) Refactor ClassLoaderAwareRemoteStorageManager.scala to ClassLoaderAwareRemoteStorageManager.java and move it to storage module.

2022-12-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14466: - Assignee: Satish Duggana (was: Luke Chen) > Refactor ClassLoaderAwareRemoteStorageManager.scal

[jira] [Comment Edited] (KAFKA-14466) Refactor ClassLoaderAwareRemoteStorageManager.scala to ClassLoaderAwareRemoteStorageManager.java and move it to storage module.

2022-12-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647977#comment-17647977 ] Luke Chen edited comment on KAFKA-14466 at 12/15/22 10:01 AM:

[jira] [Commented] (KAFKA-14466) Refactor ClassLoaderAwareRemoteStorageManager.scala to ClassLoaderAwareRemoteStorageManager.java and move it to storage module.

2022-12-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647977#comment-17647977 ] Luke Chen commented on KAFKA-14466: --- I can also help on this if you haven't started it

[jira] [Commented] (KAFKA-14467) Add a test to validate the replica state after processing the OFFSET_MOVED_TO_TIERED_STORAGE error, especially for the transactional state

2022-12-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647976#comment-17647976 ] Luke Chen commented on KAFKA-14467: --- Discussed offline, I'm going to take over this ta

[jira] [Assigned] (KAFKA-14466) Refactor ClassLoaderAwareRemoteStorageManager.scala to ClassLoaderAwareRemoteStorageManager.java and move it to storage module.

2022-12-15 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14466: - Assignee: Luke Chen (was: Satish Duggana) > Refactor ClassLoaderAwareRemoteStorageManager.scal

[jira] [Created] (KAFKA-14495) Improve the RemoteIndexCacheTest

2022-12-15 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14495: - Summary: Improve the RemoteIndexCacheTest Key: KAFKA-14495 URL: https://issues.apache.org/jira/browse/KAFKA-14495 Project: Kafka Issue Type: Sub-task R

[jira] [Commented] (KAFKA-14467) Add a test to validate the replica state after processing the OFFSET_MOVED_TO_TIERED_STORAGE error, especially for the transactional state

2022-12-13 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646966#comment-17646966 ] Luke Chen commented on KAFKA-14467: --- [~satish.duggana] , I can work on this, and you c

[jira] [Resolved] (KAFKA-14285) Delete quota node in zookeeper when configs are empty

2022-12-13 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14285. --- Fix Version/s: 3.4.1 3.5.0 Resolution: Fixed > Delete quota node in zookee

[jira] [Commented] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads.

2022-11-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640417#comment-17640417 ] Luke Chen commented on KAFKA-13560: --- https://github.com/apache/kafka/pull/11390#discus

[jira] [Commented] (KAFKA-7739) Kafka Tiered Storage

2022-11-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640344#comment-17640344 ] Luke Chen commented on KAFKA-7739: -- Thanks for the update and all the work for this feat

[jira] [Commented] (KAFKA-14421) OffsetFetchRequest throws NPE Exception

2022-11-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639811#comment-17639811 ] Luke Chen commented on KAFKA-14421: --- You can check the EOL policy here: https://cwiki

[jira] [Commented] (KAFKA-14421) OffsetFetchRequest throws NPE Exception

2022-11-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639747#comment-17639747 ] Luke Chen commented on KAFKA-14421: --- [~ws] , thanks for reporting the issue. Does this

[jira] [Commented] (KAFKA-14379) consumer should refresh preferred read replica on update metadata

2022-11-24 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638191#comment-17638191 ] Luke Chen commented on KAFKA-14379: --- Oh, sorry, I saw you have a WIP PR opened. Thanks

[jira] [Updated] (KAFKA-14379) consumer should refresh preferred read replica on update metadata

2022-11-24 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14379: -- Description: The consumer (fetcher) refreshes the preferred read replica only on three conditions: #

[jira] [Commented] (KAFKA-14379) consumer should refresh preferred read replica on update metadata

2022-11-24 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638188#comment-17638188 ] Luke Chen commented on KAFKA-14379: --- [~jeffkbkim] , we recently also encountered this

[jira] [Commented] (KAFKA-14373) provide builders for producer/consumer

2022-11-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631396#comment-17631396 ] Luke Chen commented on KAFKA-14373: --- [~scanteianu] , please remember to propose a [KI

[jira] [Commented] (KAFKA-13891) sync group failed with rebalanceInProgress error cause rebalance many rounds in coopeartive

2022-11-09 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631387#comment-17631387 ] Luke Chen commented on KAFKA-13891: --- I'm also very busy these days. [~aiquestion] , if

[jira] [Resolved] (KAFKA-14355) Integer overflow occurs in kafka-producer-perf-test.sh (class ProducerProfrmance ).

2022-11-05 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14355. --- Fix Version/s: 3.4.0 Resolution: Fixed > Integer overflow occurs in kafka-producer-perf-test.

[jira] [Commented] (KAFKA-14337) topic name with "." cannot be created after deletion

2022-10-31 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626438#comment-17626438 ] Luke Chen commented on KAFKA-14337: --- [~thanhnd96] , this bug fix will be in Kafka v3.3

[jira] [Commented] (KAFKA-13419) sync group failed with rebalanceInProgress error might cause out-of-date ownedPartition in Cooperative protocol

2022-10-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625541#comment-17625541 ] Luke Chen commented on KAFKA-13419: --- [~dajac] , you're right. We don't use owned parti

[jira] [Assigned] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14328: - Assignee: shizhenzhen > KafkaAdminClient should be Changing the exception level When an excepti

[jira] [Commented] (KAFKA-14016) Revoke more partitions than expected in Cooperative rebalance

2022-10-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625003#comment-17625003 ] Luke Chen commented on KAFKA-14016: --- [~ableegoldman] , thanks for the comment. Yes, we

[jira] [Commented] (KAFKA-13419) sync group failed with rebalanceInProgress error might cause out-of-date ownedPartition in Cooperative protocol

2022-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624885#comment-17624885 ] Luke Chen commented on KAFKA-13419: --- [~ableegoldman] , you are right. We have the logi

[jira] [Commented] (KAFKA-13999) Add ProducerCount metrics (KIP-847)

2022-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624331#comment-17624331 ] Luke Chen commented on KAFKA-13999: --- [~alivshits] , will this feature complete in v3.4

[jira] [Updated] (KAFKA-14337) topic name with "." cannot be created after deletion

2022-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14337: -- Component/s: kraft (was: admin) > topic name with "." cannot be created after del

[jira] [Updated] (KAFKA-14337) topic name with "." cannot be created after deletion

2022-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14337: -- Labels: (was: pull-request-available) > topic name with "." cannot be created after deletion > -

[jira] [Updated] (KAFKA-14337) topic name with "." cannot be created after deletion

2022-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14337: -- Environment: (was: Stagging) > topic name with "." cannot be created after deletion >

[jira] [Updated] (KAFKA-14337) topic name with "." cannot be created after deletion

2022-10-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14337: -- Summary: topic name with "." cannot be created after deletion (was: bugs kafka 3.3.1 create topic aft

[jira] [Commented] (KAFKA-14337) bugs kafka 3.3.1 create topic after delete topic

2022-10-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624189#comment-17624189 ] Luke Chen commented on KAFKA-14337: --- Nice find! Investigating!   > bugs kafka 3.3.1

[jira] [Assigned] (KAFKA-14337) bugs kafka 3.3.1 create topic after delete topic

2022-10-25 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14337: - Assignee: Luke Chen > bugs kafka 3.3.1 create topic after delete topic > --

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622909#comment-17622909 ] Luke Chen commented on KAFKA-14328: --- I understand your problem now. But I'm not quite

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-20 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621522#comment-17621522 ] Luke Chen commented on KAFKA-14328: --- I think we log as trace level is because they are

[jira] [Commented] (KAFKA-14313) Kraft: immediately producing to new topics occasionally returns NOT_LEADER_FOR_PARTITION

2022-10-18 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619308#comment-17619308 ] Luke Chen commented on KAFKA-14313: --- [~dengziming] , the issue is discussed [here|htt

[jira] [Created] (KAFKA-14308) metadata shell might not need to handle leader change message

2022-10-17 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14308: - Summary: metadata shell might not need to handle leader change message Key: KAFKA-14308 URL: https://issues.apache.org/jira/browse/KAFKA-14308 Project: Kafka Issu

[jira] [Resolved] (KAFKA-14280) quorum election random backoff always return 0 for 1st retry

2022-10-16 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14280. --- Resolution: Not A Problem Closed as not a problem   > quorum election random backoff always return

[jira] [Commented] (KAFKA-14303) Producer.send without record key and batch.size=0 goes into infinite loop

2022-10-14 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617696#comment-17617696 ] Luke Chen commented on KAFKA-14303: --- [~soarez] , thanks for reporting the issue. Looks

[jira] [Commented] (KAFKA-14287) Multi noded with kraft combined mode will fail shutdown

2022-10-14 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617521#comment-17617521 ] Luke Chen commented on KAFKA-14287: --- Thanks for the reply. But I don't know how we can

[jira] [Updated] (KAFKA-14287) Multi noded with kraft combined mode will fail shutdown

2022-10-11 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14287: -- Description: Multiple nodes with kraft combined mode (i.e. process.roles='broker,controller') can sta

[jira] [Updated] (KAFKA-14287) Multi noded with kraft combined mode will fail shutdown

2022-10-11 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14287: -- Description: Multiple nodes with kraft combined mode (i.e. process.roles='broker,controller') can sta

[jira] [Commented] (KAFKA-14287) Multi noded with kraft combined mode will fail shutdown

2022-10-11 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615658#comment-17615658 ] Luke Chen commented on KAFKA-14287: --- [~dengziming] [~jsancio] [~hachikuji] , any thoug

[jira] [Created] (KAFKA-14287) Multi noded with kraft combined mode will fail shutdown

2022-10-11 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14287: - Summary: Multi noded with kraft combined mode will fail shutdown Key: KAFKA-14287 URL: https://issues.apache.org/jira/browse/KAFKA-14287 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14284) "current-vote" metric is always leaderId under non-election state

2022-10-07 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14284: - Summary: "current-vote" metric is always leaderId under non-election state Key: KAFKA-14284 URL: https://issues.apache.org/jira/browse/KAFKA-14284 Project: Kafka

[jira] [Updated] (KAFKA-14280) quorum election random backoff always return 0 for 1st retry

2022-10-04 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14280: -- Description: When doing quorum election, we added a random election backoff if vote got rejected or t

[jira] [Updated] (KAFKA-14280) quorum election random backoff always return 0 for 1st retry

2022-10-04 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14280: -- Summary: quorum election random backoff always return 0 for 1st retry (was: quorum election random ba

[jira] [Created] (KAFKA-14280) quorum election random backoff always return 0 for 1st timeout

2022-10-04 Thread Luke Chen (Jira)
Luke Chen created KAFKA-14280: - Summary: quorum election random backoff always return 0 for 1st timeout Key: KAFKA-14280 URL: https://issues.apache.org/jira/browse/KAFKA-14280 Project: Kafka Iss

<    2   3   4   5   6   7   8   9   10   11   >