[jira] [Commented] (KAFKA-14083) Check if we don't need to refresh time in RecordAccumulator.append

[ https://issues.apache.org/jira/browse/KAFKA-14083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570311#comment-17570311 ] Kvicii.Yu commented on KAFKA-14083: --- PR merged, So we need close this. > Check if we

[jira] [Commented] (KAFKA-14085) Clean up usage of asserts in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-14085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570310#comment-17570310 ] Kvicii.Yu commented on KAFKA-14085: --- PR merged, So we need close this. > Clean up usa

[jira] [Commented] (KAFKA-14086) Cleanup PlaintextConsumerTest.testInterceptors to not pass null record

[ https://issues.apache.org/jira/browse/KAFKA-14086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570309#comment-17570309 ] Kvicii.Yu commented on KAFKA-14086: --- PR merged, So we need close this. > Cleanup Plai

[jira] [Commented] (KAFKA-14019) removeMembersFromConsumerGroup can't delete all members when there is no members already

[ https://issues.apache.org/jira/browse/KAFKA-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570307#comment-17570307 ] Kvicii.Yu commented on KAFKA-14019: --- [~chia7712]  hi, your meaning we need change this

[jira] [Commented] (KAFKA-13974) Rename `INVALID_UPDATE_VERSION` to `INVALID_PARTITION_EPOCH`

[ https://issues.apache.org/jira/browse/KAFKA-13974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556458#comment-17556458 ] Kvicii.Yu commented on KAFKA-13974: --- ok, if have some simple issue, you can tag with i

[jira] [Commented] (KAFKA-13974) Rename `INVALID_UPDATE_VERSION` to `INVALID_PARTITION_EPOCH`

[ https://issues.apache.org/jira/browse/KAFKA-13974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556428#comment-17556428 ] Kvicii.Yu commented on KAFKA-13974: --- [~dajac]  hi, are you fixed this? if not, I will

[jira] [Assigned] (KAFKA-13971) Atomicity violations caused by improper usage of ConcurrentHashMap

[ https://issues.apache.org/jira/browse/KAFKA-13971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kvicii.Yu reassigned KAFKA-13971: - Assignee: Kvicii.Yu > Atomicity violations caused by improper usage of ConcurrentHashMap >

[jira] [Commented] (KAFKA-13971) Atomicity violations caused by improper usage of ConcurrentHashMap

[ https://issues.apache.org/jira/browse/KAFKA-13971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552297#comment-17552297 ] Kvicii.Yu commented on KAFKA-13971: --- looks good. Iagree. > Atomicity violations cause

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542925#comment-17542925 ] Kvicii.Yu commented on KAFKA-13592: --- [~divijvaidya] ok, let me see. > Fix flaky test

[jira] [Commented] (KAFKA-13856) MirrorCheckpointTask meets ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540430#comment-17540430 ] Kvicii.Yu commented on KAFKA-13856: --- [~Justinwins]  we use ConcurrentHashMap instead o

[jira] [Comment Edited] (KAFKA-13867) Improve JavaDoc for MetadataVersion.java

[ https://issues.apache.org/jira/browse/KAFKA-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537864#comment-17537864 ] Kvicii.Yu edited comment on KAFKA-13867 at 5/17/22 1:24 AM:

[jira] [Commented] (KAFKA-13867) Improve JavaDoc for MetadataVersion.java

[ https://issues.apache.org/jira/browse/KAFKA-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537864#comment-17537864 ] Kvicii.Yu commented on KAFKA-13867: --- [~cmccabe] hi, My understanding is to just modify

[jira] [Commented] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487431#comment-17487431 ] Kvicii.Yu commented on KAFKA-13641: --- [~yzia2000]  I don't think it's a good idea to m

[jira] [Commented] (KAFKA-13641) Kafka Streams Scala: Add `Option` to `ValueJoiner` parameters

[ https://issues.apache.org/jira/browse/KAFKA-13641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486378#comment-17486378 ] Kvicii.Yu commented on KAFKA-13641: --- [~yzia2000]  hi, I didn't understand what you me

[jira] [Commented] (KAFKA-13626) NullPointerException in Selector.pollSelectionKeys: channel is null

[ https://issues.apache.org/jira/browse/KAFKA-13626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485879#comment-17485879 ] Kvicii.Yu commented on KAFKA-13626: --- [~haeuserd]   Thanks for your report, but what e

[jira] [Commented] (KAFKA-13620) The request handler metric name for ControllerApis should be different than KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-13620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483128#comment-17483128 ] Kvicii.Yu commented on KAFKA-13620: --- [~cmccabe]  hi, did you mean function name? > Th

[jira] [Created] (KAFKA-13618) BatchAccumulator `Exptected` rename to `Expected`

Kvicii.Yu created KAFKA-13618: - Summary: BatchAccumulator `Exptected` rename to `Expected` Key: KAFKA-13618 URL: https://issues.apache.org/jira/browse/KAFKA-13618 Project: Kafka Issue Type: Impro

[jira] [Commented] (KAFKA-13606) MirrorCheckpointTask doesn't check offsets sync result

[ https://issues.apache.org/jira/browse/KAFKA-13606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480490#comment-17480490 ] Kvicii.Yu commented on KAFKA-13606: --- [~savulchik]  Therefore, my understanding is tha

[jira] [Commented] (KAFKA-13606) MirrorCheckpointTask doesn't check offsets sync result

[ https://issues.apache.org/jira/browse/KAFKA-13606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480369#comment-17480369 ] Kvicii.Yu commented on KAFKA-13606: --- hi, [~savulchik] Can you elaborate on how this pr

[jira] [Updated] (KAFKA-12831) Remove Deprecated method StateStore#init

[ https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kvicii.Yu updated KAFKA-12831: -- Description: The method org.apache.kafka.streams.processor.StateStore#init(org.apache.kafka.streams.p

[jira] [Updated] (KAFKA-12831) Remove Deprecated method StateStore#init

[ https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kvicii.Yu updated KAFKA-12831: -- Description: 方法 org.apache.kafka.streams.processor.StateStore#init(org.apache.kafka.streams.processor

[jira] [Assigned] (KAFKA-13583) Fix FetchRequestBetweenDifferentIbpTest flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-13583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kvicii.Yu reassigned KAFKA-13583: - Assignee: Kvicii.Yu > Fix FetchRequestBetweenDifferentIbpTest flaky tests > ---

[jira] [Comment Edited] (KAFKA-13583) Fix FetchRequestBetweenDifferentIbpTest flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-13583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480165#comment-17480165 ] Kvicii.Yu edited comment on KAFKA-13583 at 1/21/22, 4:23 PM: -

[jira] [Commented] (KAFKA-13583) Fix FetchRequestBetweenDifferentIbpTest flaky tests

[ https://issues.apache.org/jira/browse/KAFKA-13583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480165#comment-17480165 ] Kvicii.Yu commented on KAFKA-13583: --- [~dajac] hi, I followed your advice and tried les

[jira] [Commented] (KAFKA-13584) Fix `kafka.network.SocketServerTest.testUnmuteChannelWithBufferedReceives` flaky test

[ https://issues.apache.org/jira/browse/KAFKA-13584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478742#comment-17478742 ] Kvicii.Yu commented on KAFKA-13584: --- [~dajac]  hello, I will try fix this test, maybe

[jira] [Commented] (KAFKA-13590) Rename InternalTopologyBuilder's #topicGroups method to be more descriptive

[ https://issues.apache.org/jira/browse/KAFKA-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478702#comment-17478702 ] Kvicii.Yu commented on KAFKA-13590: --- [~ableegoldman] i think `topicGroupsInfo` may be

[jira] (KAFKA-13590) Rename InternalTopologyBuilder's #topicGroups method to be more descriptive

[ https://issues.apache.org/jira/browse/KAFKA-13590 ] Kvicii.Yu deleted comment on KAFKA-13590: --- was (Author: JIRAUSER283467): rename is a problem.But what is more appropriate? > Rename InternalTopologyBuilder's #topicGroups method to be more des

[jira] [Commented] (KAFKA-13596) ERROR Error while deleting segments for {topic} : java.nio.file.NoSuchFileException

[ https://issues.apache.org/jira/browse/KAFKA-13596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477918#comment-17477918 ] Kvicii.Yu commented on KAFKA-13596: --- [~shiyc]  Could you tell me how can I reproduce

[jira] [Commented] (KAFKA-13581) Error getting old protocol

[ https://issues.apache.org/jira/browse/KAFKA-13581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477859#comment-17477859 ] Kvicii.Yu commented on KAFKA-13581: --- [~chenzy] thanks for your reporting. In fact, I

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477709#comment-17477709 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 1:13 PM: -

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477709#comment-17477709 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 1:11 PM: -

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477709#comment-17477709 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 11:09 AM:

[jira] [Assigned] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kvicii.Yu reassigned KAFKA-13592: - Assignee: Kvicii.Yu > Fix flaky test > ControllerIntegrationTest.testTopicIdUpgradeAfterReassi

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477709#comment-17477709 ] Kvicii.Yu commented on KAFKA-13592: --- [~dajac] thanks a lot.bro > Fix flaky test > Co

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477490#comment-17477490 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 1:43 AM: -

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477490#comment-17477490 ] Kvicii.Yu commented on KAFKA-13592: --- [~dajac] I would like to give this a go so that I

[jira] [Commented] (KAFKA-13590) Rename InternalTopologyBuilder's #topicGroups method to be more descriptive

[ https://issues.apache.org/jira/browse/KAFKA-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476271#comment-17476271 ] Kvicii.Yu commented on KAFKA-13590: --- rename is a problem.But what is more appropriate?

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476170#comment-17476170 ] Kvicii.Yu commented on KAFKA-13592: --- [~dajac] hello, can i do this? > Fix flaky test

[jira] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592 ] Kvicii.Yu deleted comment on KAFKA-13592: --- was (Author: JIRAUSER283467): Can you provide a kafka version? > Fix flaky test > ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartit

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476165#comment-17476165 ] Kvicii.Yu commented on KAFKA-13592: --- Can you provide a kafka version? > Fix flaky tes

[jira] (KAFKA-12689) Remove deprecated EOS configs

[ https://issues.apache.org/jira/browse/KAFKA-12689 ] Kvicii.Yu deleted comment on KAFKA-12689: --- was (Author: JIRAUSER283467): [~loboxu] could i close this? > Remove deprecated EOS configs > - > > Key:

[jira] [Commented] (KAFKA-12689) Remove deprecated EOS configs

[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476157#comment-17476157 ] Kvicii.Yu commented on KAFKA-12689: --- [~loboxu] could i close this? > Remove deprecate

[jira] [Commented] (KAFKA-2953) Kafka documentation is really wide

[ https://issues.apache.org/jira/browse/KAFKA-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475380#comment-17475380 ] Kvicii.Yu commented on KAFKA-2953: -- I think it's also important to have multilingual doc

[jira] [Commented] (KAFKA-9135) Kafka producer/consumer are creating too many open file

[ https://issues.apache.org/jira/browse/KAFKA-9135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475375#comment-17475375 ] Kvicii.Yu commented on KAFKA-9135: -- Do you know your machine's corpus handle number conf

[jira] [Commented] (KAFKA-7148) Kafka load log very slow after goes down with outOfMemoryError

[ https://issues.apache.org/jira/browse/KAFKA-7148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475371#comment-17475371 ] Kvicii.Yu commented on KAFKA-7148: -- This should appear when rebuilding the index, you ca