[jira] [Assigned] (KAFKA-13403) KafkaServer crashes when deleting topics due to the race in log deletion

[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-13403: Assignee: Arun Mathew (was: Haruki Okada) > KafkaServer crashes when deleting topics due

[jira] [Commented] (KAFKA-17076) logEndOffset could be lost due to log cleaning

[ https://issues.apache.org/jira/browse/KAFKA-17076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866105#comment-17866105 ] Haruki Okada commented on KAFKA-17076: -- Also, since lastOffset() always returns ori

[jira] [Commented] (KAFKA-17076) logEndOffset could be lost due to log cleaning

[ https://issues.apache.org/jira/browse/KAFKA-17076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865823#comment-17865823 ] Haruki Okada commented on KAFKA-17076: -- [~junrao] Is that possible? At the step 2

[jira] [Commented] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865110#comment-17865110 ] Haruki Okada commented on KAFKA-17061: -- Did a micro benchmark to check the performa

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Description: h2. Environment * Kafka version: 3.3.2 * Cluster: 200~ brokers * Total num parti

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Attachment: screenshot-flame-patched.png > KafkaController takes long time to connect to newly a

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Attachment: screenshot-flame.png > KafkaController takes long time to connect to newly added bro

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Attachment: flame-patched.html > KafkaController takes long time to connect to newly added broke

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Attachment: flame.html > KafkaController takes long time to connect to newly added broker after

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Description: h2. Environment * Kafka version: 3.3.2 * Cluster: 200~ brokers * Total num parti

[jira] [Commented] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863197#comment-17863197 ] Haruki Okada commented on KAFKA-17061: -- [~showuon] Hi, I submitted a [patch|https:

[jira] [Updated] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-17061: - Description: h2. Environment * Kafka version: 3.3.2 * Cluster: 200~ brokers * Total num parti

[jira] [Assigned] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

[ https://issues.apache.org/jira/browse/KAFKA-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-17061: Assignee: Haruki Okada > KafkaController takes long time to connect to newly added broker

[jira] [Created] (KAFKA-17061) KafkaController takes long time to connect to newly added broker after registration on large cluster

Haruki Okada created KAFKA-17061: Summary: KafkaController takes long time to connect to newly added broker after registration on large cluster Key: KAFKA-17061 URL: https://issues.apache.org/jira/browse/KAFKA-170

[jira] [Commented] (KAFKA-15612) Followup on whether the segment indexes need to be materialized or flushed before they are passed to RSM for writing them to tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856223#comment-17856223 ] Haruki Okada commented on KAFKA-15612: -- In my understanding, we concluded that inde

[jira] [Commented] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever

[ https://issues.apache.org/jira/browse/KAFKA-16916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853312#comment-17853312 ] Haruki Okada commented on KAFKA-16916: -- Seems [~apoorvmittal10] already identified

[jira] [Assigned] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever

[ https://issues.apache.org/jira/browse/KAFKA-16916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-16916: Assignee: Apoorv Mittal (was: Haruki Okada) > ClientAuthenticationFailureTest.testAdminC

[jira] [Commented] (KAFKA-16541) Potential leader epoch checkpoint file corruption on OS crash

[ https://issues.apache.org/jira/browse/KAFKA-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847684#comment-17847684 ] Haruki Okada commented on KAFKA-16541: -- [~junrao] Hi, i've just submitted a patch.

[jira] [Commented] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843116#comment-17843116 ] Haruki Okada commented on KAFKA-16372: -- [~mpedersencrwd] In either case, it takes t

[jira] [Commented] (KAFKA-16541) Potential leader epoch checkpoint file corruption on OS crash

[ https://issues.apache.org/jira/browse/KAFKA-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842816#comment-17842816 ] Haruki Okada commented on KAFKA-16541: -- [~junrao] Yes. My concern now is only chang

[jira] [Commented] (KAFKA-16651) KafkaProducer.send does not throw TimeoutException as documented

[ https://issues.apache.org/jira/browse/KAFKA-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842582#comment-17842582 ] Haruki Okada commented on KAFKA-16651: -- Might be duplicated: https://issues.apache.

[jira] [Created] (KAFKA-16541) Potential leader epoch checkpoint file corruption on OS crash

Haruki Okada created KAFKA-16541: Summary: Potential leader epoch checkpoint file corruption on OS crash Key: KAFKA-16541 URL: https://issues.apache.org/jira/browse/KAFKA-16541 Project: Kafka

[jira] [Assigned] (KAFKA-16393) SslTransportLayer doesn't implement write(ByteBuffer[], int, int) correctly

[ https://issues.apache.org/jira/browse/KAFKA-16393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-16393: Assignee: Haruki Okada > SslTransportLayer doesn't implement write(ByteBuffer[], int, int

[jira] [Created] (KAFKA-16393) SslTransportLayer doesn't implement write(ByteBuffer[], int, int) correctly

Haruki Okada created KAFKA-16393: Summary: SslTransportLayer doesn't implement write(ByteBuffer[], int, int) correctly Key: KAFKA-16393 URL: https://issues.apache.org/jira/browse/KAFKA-16393 Project:

[jira] [Comment Edited] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828960#comment-17828960 ] Haruki Okada edited comment on KAFKA-16372 at 3/20/24 2:16 PM: ---

[jira] [Assigned] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-16372: Assignee: Haruki Okada > max.block.ms behavior inconsistency with javadoc and the config

[jira] [Comment Edited] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828960#comment-17828960 ] Haruki Okada edited comment on KAFKA-16372 at 3/20/24 2:15 PM: ---

[jira] [Commented] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828960#comment-17828960 ] Haruki Okada commented on KAFKA-16372: -- [~showuon] Agreed. One concern is, IMO many

[jira] [Updated] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-16372: - Description: As of Kafka 3.7.0, the javadoc of [KafkaProducer.send|https://github.com/apache/ka

[jira] [Updated] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-16372: - Component/s: producer (was: clients) Priority: Minor (was: Major)

[jira] [Created] (KAFKA-16372) max.block.ms behavior inconsistency with javadoc and the config description

Haruki Okada created KAFKA-16372: Summary: max.block.ms behavior inconsistency with javadoc and the config description Key: KAFKA-16372 URL: https://issues.apache.org/jira/browse/KAFKA-16372 Project:

[jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll

[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791354#comment-17791354 ] Haruki Okada commented on KAFKA-9693: - [~paolomoriello] [~novosibman] Hi, I believe t

[jira] [Created] (KAFKA-15924) Flaky test - QuorumControllerTest.testFatalMetadataReplayErrorOnActive

Haruki Okada created KAFKA-15924: Summary: Flaky test - QuorumControllerTest.testFatalMetadataReplayErrorOnActive Key: KAFKA-15924 URL: https://issues.apache.org/jira/browse/KAFKA-15924 Project: Kafka

[jira] [Updated] (KAFKA-15924) Flaky test - QuorumControllerTest.testFatalMetadataReplayErrorOnActive

[ https://issues.apache.org/jira/browse/KAFKA-15924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15924: - Attachment: stdout.log > Flaky test - QuorumControllerTest.testFatalMetadataReplayErrorOnActive

[jira] [Updated] (KAFKA-15920) Flaky test - PlaintextConsumerTest.testCoordinatorFailover

[ https://issues.apache.org/jira/browse/KAFKA-15920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15920: - Attachment: stdout.log > Flaky test - PlaintextConsumerTest.testCoordinatorFailover > --

[jira] [Updated] (KAFKA-15921) Flaky test - SaslScramSslEndToEndAuthorizationTest.testAuthentications

[ https://issues.apache.org/jira/browse/KAFKA-15921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15921: - Attachment: stdout.log > Flaky test - SaslScramSslEndToEndAuthorizationTest.testAuthentications

[jira] [Updated] (KAFKA-15919) Flaky test - BrokerLifecycleManagerTest.testAlwaysSendsAccumulatedOfflineDirs

[ https://issues.apache.org/jira/browse/KAFKA-15919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15919: - Description: [https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR

[jira] [Updated] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets

[ https://issues.apache.org/jira/browse/KAFKA-15918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15918: - Attachment: stdout.log > Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets >

[jira] [Updated] (KAFKA-15917) Flaky test - OffsetsApiIntegrationTest.testAlterSinkConnectorOffsetsZombieSinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-15917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15917: - Attachment: stdout.log > Flaky test - > OffsetsApiIntegrationTest.testAlterSinkConnectorOffsets

[jira] [Created] (KAFKA-15921) Flaky test - SaslScramSslEndToEndAuthorizationTest.testAuthentications

Haruki Okada created KAFKA-15921: Summary: Flaky test - SaslScramSslEndToEndAuthorizationTest.testAuthentications Key: KAFKA-15921 URL: https://issues.apache.org/jira/browse/KAFKA-15921 Project: Kafka

[jira] [Created] (KAFKA-15920) Flaky test - PlaintextConsumerTest.testCoordinatorFailover

Haruki Okada created KAFKA-15920: Summary: Flaky test - PlaintextConsumerTest.testCoordinatorFailover Key: KAFKA-15920 URL: https://issues.apache.org/jira/browse/KAFKA-15920 Project: Kafka Is

[jira] [Updated] (KAFKA-15917) Flaky test - OffsetsApiIntegrationTest.testAlterSinkConnectorOffsetsZombieSinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-15917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15917: - Summary: Flaky test - OffsetsApiIntegrationTest.testAlterSinkConnectorOffsetsZombieSinkTasks (w

[jira] [Created] (KAFKA-15919) Flaky test - BrokerLifecycleManagerTest.testAlwaysSendsAccumulatedOfflineDirs

Haruki Okada created KAFKA-15919: Summary: Flaky test - BrokerLifecycleManagerTest.testAlwaysSendsAccumulatedOfflineDirs Key: KAFKA-15919 URL: https://issues.apache.org/jira/browse/KAFKA-15919 Project

[jira] [Updated] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets

[ https://issues.apache.org/jira/browse/KAFKA-15918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15918: - Summary: Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets (was: Flaky test

[jira] [Created] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest. testResetSinkConnectorOffsets

Haruki Okada created KAFKA-15918: Summary: Flaky test - OffsetsApiIntegrationTest. testResetSinkConnectorOffsets Key: KAFKA-15918 URL: https://issues.apache.org/jira/browse/KAFKA-15918 Project: Kafka

[jira] [Created] (KAFKA-15917) Flaky test - OffsetsApiIntegrationTest. testAlterSinkConnectorOffsetsZombieSinkTasks

Haruki Okada created KAFKA-15917: Summary: Flaky test - OffsetsApiIntegrationTest. testAlterSinkConnectorOffsetsZombieSinkTasks Key: KAFKA-15917 URL: https://issues.apache.org/jira/browse/KAFKA-15917

[jira] [Commented] (KAFKA-15609) Corrupted index uploaded to remote tier

[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1778#comment-1778 ] Haruki Okada commented on KAFKA-15609: -- I added [MmapTest3.java|https://gist.githu

[jira] [Comment Edited] (KAFKA-15609) Corrupted index uploaded to remote tier

[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782194#comment-17782194 ] Haruki Okada edited comment on KAFKA-15609 at 11/2/23 3:36 PM: ---

[jira] [Comment Edited] (KAFKA-15609) Corrupted index uploaded to remote tier

[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782202#comment-17782202 ] Haruki Okada edited comment on KAFKA-15609 at 11/2/23 4:12 PM: ---

[jira] [Commented] (KAFKA-15609) Corrupted index uploaded to remote tier

[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782194#comment-17782194 ] Haruki Okada commented on KAFKA-15609: -- [~divijvaidya] Right, when we call two mma

[jira] [Commented] (KAFKA-15609) Corrupted index uploaded to remote tier

[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782202#comment-17782202 ] Haruki Okada commented on KAFKA-15609: -- I validated the MappedByteBuffer behavior w

[jira] [Commented] (KAFKA-15688) Partition leader election not running when disk IO hangs

[ https://issues.apache.org/jira/browse/KAFKA-15688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779956#comment-17779956 ] Haruki Okada commented on KAFKA-15688: -- > Is it possible to add such a feature to K

[jira] [Commented] (KAFKA-15609) Corrupted index uploaded to remote tier

[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775965#comment-17775965 ] Haruki Okada commented on KAFKA-15609: -- > is the OS intelligent enough to understan

[jira] [Created] (KAFKA-15567) ReplicaFetcherThreadBenchmark is not working

Haruki Okada created KAFKA-15567: Summary: ReplicaFetcherThreadBenchmark is not working Key: KAFKA-15567 URL: https://issues.apache.org/jira/browse/KAFKA-15567 Project: Kafka Issue Type: Impr

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758588#comment-17758588 ] Haruki Okada commented on KAFKA-7504: - I would like to bump this issue up again since

[jira] [Commented] (KAFKA-15391) Delete topic may lead to directory offline

[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758026#comment-17758026 ] Haruki Okada commented on KAFKA-15391: -- For this issue, we may need to swallow NoSu

[jira] [Assigned] (KAFKA-15391) Delete topic may lead to directory offline

[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-15391: Assignee: Haruki Okada > Delete topic may lead to directory offline > ---

[jira] [Commented] (KAFKA-15391) Delete topic may lead to directory offline

[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757792#comment-17757792 ] Haruki Okada commented on KAFKA-15391: -- May I take this ticket? I'm interested sin

[jira] [Commented] (KAFKA-15391) Delete topic may lead to directory offline

[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757442#comment-17757442 ] Haruki Okada commented on KAFKA-15391: -- I see, understood. Thanks > Delete topic m

[jira] [Comment Edited] (KAFKA-15391) Delete topic may lead to directory offline

[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757388#comment-17757388 ] Haruki Okada edited comment on KAFKA-15391 at 8/22/23 11:57 AM: --

[jira] [Commented] (KAFKA-15391) Delete topic may lead to directory offline

[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757388#comment-17757388 ] Haruki Okada commented on KAFKA-15391: -- Related? https://issues.apache.org/jira/bro

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755904#comment-17755904 ] Haruki Okada edited comment on KAFKA-15046 at 8/18/23 12:05 PM: --

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755904#comment-17755904 ] Haruki Okada commented on KAFKA-15046: -- I submitted a patch [https://github.com/apa

[jira] [Updated] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15046: - Attachment: image-2023-08-18-19-29-56-377.png > Produce performance issue under high disk load >

[jira] [Updated] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15046: - Attachment: image-2023-08-18-19-23-36-597.png > Produce performance issue under high disk load >

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755898#comment-17755898 ] Haruki Okada commented on KAFKA-15046: -- After dug into the fsync call paths in deta

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755351#comment-17755351 ] Haruki Okada edited comment on KAFKA-15046 at 8/17/23 4:09 AM: ---

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755351#comment-17755351 ] Haruki Okada edited comment on KAFKA-15046 at 8/17/23 4:08 AM: ---

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755351#comment-17755351 ] Haruki Okada commented on KAFKA-15046: -- [~junrao] Hi, sorry for the late response.

[jira] [Commented] (KAFKA-15185) Consumers using the latest strategy may lose data after the topic adds partitions

[ https://issues.apache.org/jira/browse/KAFKA-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742830#comment-17742830 ] Haruki Okada commented on KAFKA-15185: -- FYI: maybe duplicated with https://issues.a

[jira] [Assigned] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-14445: Assignee: Haruki Okada > Producer doesn't request metadata update on REQUEST_TIMED_OUT >

[jira] [Commented] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729695#comment-17729695 ] Haruki Okada commented on KAFKA-14445: -- [~kirktrue] Thanks for your patch about ht

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729561#comment-17729561 ] Haruki Okada commented on KAFKA-15046: -- I see, thank you for pointing out. Hmm, no

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728551#comment-17728551 ] Haruki Okada edited comment on KAFKA-15046 at 6/2/23 7:19 AM:

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728551#comment-17728551 ] Haruki Okada commented on KAFKA-15046: -- [~showuon]  Maybe I linked wrong file. Wha

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728515#comment-17728515 ] Haruki Okada edited comment on KAFKA-15046 at 6/2/23 4:01 AM:

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728515#comment-17728515 ] Haruki Okada commented on KAFKA-15046: -- Yeah, io_uring is promising. However it on

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728515#comment-17728515 ] Haruki Okada edited comment on KAFKA-15046 at 6/2/23 12:01 AM: ---

[jira] [Updated] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15046: - Description: * Phenomenon: ** !image-2023-06-01-12-46-30-058.png|width=259,height=236! ** Prod

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728266#comment-17728266 ] Haruki Okada edited comment on KAFKA-15046 at 6/1/23 8:39 AM:

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728266#comment-17728266 ] Haruki Okada commented on KAFKA-15046: -- Hm, when I dug into further this, I noticed

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728262#comment-17728262 ] Haruki Okada commented on KAFKA-15046: -- Oh I haven't noticed there's another ticket

[jira] [Updated] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15046: - Description: * Phenomenon: ** !image-2023-06-01-12-46-30-058.png|width=259,height=236! ** Prod

[jira] [Updated] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15046: - Description: * Phenomenon: ** !image-2023-06-01-12-46-30-058.png|width=259,height=236! ** Prod

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728214#comment-17728214 ] Haruki Okada commented on KAFKA-15046: -- If the suggestion (stop fsync-ing) makes se

[jira] [Updated] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15046: - Description: * Phenomenon: ** !image-2023-06-01-12-46-30-058.png|width=259,height=236! ** Prod

[jira] [Created] (KAFKA-15046) Produce performance issue under high disk load

Haruki Okada created KAFKA-15046: Summary: Produce performance issue under high disk load Key: KAFKA-15046 URL: https://issues.apache.org/jira/browse/KAFKA-15046 Project: Kafka Issue Type: Im

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

[ https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693013#comment-17693013 ] Haruki Okada commented on KAFKA-14757: -- Possibly related: https://issues.apache.org

[jira] [Commented] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644055#comment-17644055 ] Haruki Okada commented on KAFKA-14445: -- [~kirktrue] Oh I was not aware of KAFKA-143

[jira] [Updated] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-14445: - Description: Produce requests may fail with timeout by `request.timeout.ms` in below two cases:

[jira] [Updated] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-14445: - Description: Produce requests may fail with timeout by `request.timeout.ms` in below two cases:

[jira] [Commented] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643768#comment-17643768 ] Haruki Okada commented on KAFKA-14445: -- If the suggestion makes sense, we're happy

[jira] [Created] (KAFKA-14445) Producer doesn't request metadata update on REQUEST_TIMED_OUT

Haruki Okada created KAFKA-14445: Summary: Producer doesn't request metadata update on REQUEST_TIMED_OUT Key: KAFKA-14445 URL: https://issues.apache.org/jira/browse/KAFKA-14445 Project: Kafka

[jira] [Commented] (KAFKA-13572) Negative value for 'Preferred Replica Imbalance' metric

[ https://issues.apache.org/jira/browse/KAFKA-13572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566872#comment-17566872 ] Haruki Okada commented on KAFKA-13572: -- We experienced similar phenomenon in our Ka

[jira] [Comment Edited] (KAFKA-13403) KafkaServer crashes when deleting topics due to the race in log deletion

[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527800#comment-17527800 ] Haruki Okada edited comment on KAFKA-13403 at 4/26/22 7:35 AM: ---

[jira] [Commented] (KAFKA-13855) FileNotFoundException: Error while rolling log segment for topic partition in dir

[ https://issues.apache.org/jira/browse/KAFKA-13855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527961#comment-17527961 ] Haruki Okada commented on KAFKA-13855: -- H-mm sorry, sounds like I just overstepped.

[jira] [Commented] (KAFKA-13403) KafkaServer crashes when deleting topics due to the race in log deletion

[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527800#comment-17527800 ] Haruki Okada commented on KAFKA-13403: -- [~showuon] Hi, could you help reviewing the

[jira] [Commented] (KAFKA-13855) FileNotFoundException: Error while rolling log segment for topic partition in dir

[ https://issues.apache.org/jira/browse/KAFKA-13855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527797#comment-17527797 ] Haruki Okada commented on KAFKA-13855: -- I guess that's same cause as https://issues

[jira] [Comment Edited] (KAFKA-10690) Produce-response delay caused by lagging replica fetch which affects in-sync one

[ https://issues.apache.org/jira/browse/KAFKA-10690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503911#comment-17503911 ] Haruki Okada edited comment on KAFKA-10690 at 3/10/22, 12:14 AM: -

[jira] [Commented] (KAFKA-10690) Produce-response delay caused by lagging replica fetch which affects in-sync one

[ https://issues.apache.org/jira/browse/KAFKA-10690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503911#comment-17503911 ] Haruki Okada commented on KAFKA-10690: -- Thanks for the comment.    [~showuon]   

  1   2   >