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

2024-05-19 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847684#comment-17847684 ] Haruki Okada commented on KAFKA-16541: -- [~junrao] Hi, i've just submitted a patch. PTAL >

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

2024-05-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843116#comment-17843116 ] Haruki Okada commented on KAFKA-16372: -- [~mpedersencrwd] In either case, it takes time to fix

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

2024-05-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842816#comment-17842816 ] Haruki Okada commented on KAFKA-16541: -- [~junrao] Yes. My concern now is only changing renameDir

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

2024-05-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842582#comment-17842582 ] Haruki Okada commented on KAFKA-16651: -- Might be duplicated:

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

2024-04-11 Thread Haruki Okada (Jira)
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

2024-03-21 Thread Haruki Okada (Jira)
[ 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,

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

2024-03-20 Thread Haruki Okada (Jira)
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

2024-03-20 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828960#comment-17828960 ] Haruki Okada edited comment on KAFKA-16372 at 3/20/24 2:16 PM: --- [~showuon]

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

2024-03-20 Thread Haruki Okada (Jira)
[ 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

2024-03-20 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828960#comment-17828960 ] Haruki Okada edited comment on KAFKA-16372 at 3/20/24 2:15 PM: --- [~showuon]

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

2024-03-20 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828960#comment-17828960 ] Haruki Okada commented on KAFKA-16372: -- [~showuon] Agreed. One concern is, IMO many developers

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

2024-03-14 Thread Haruki Okada (Jira)
[ 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

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

2024-03-14 Thread Haruki Okada (Jira)
[ 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

2024-03-14 Thread Haruki Okada (Jira)
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

2023-11-29 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791354#comment-17791354 ] Haruki Okada commented on KAFKA-9693: - [~paolomoriello] [~novosibman] Hi, I believe the latency spike

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

2023-11-29 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-15924: Summary: Flaky test - QuorumControllerTest.testFatalMetadataReplayErrorOnActive Key: KAFKA-15924 URL: https://issues.apache.org/jira/browse/KAFKA-15924 Project:

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

2023-11-29 Thread Haruki Okada (Jira)
[ 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

2023-11-28 Thread Haruki Okada (Jira)
[ 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

2023-11-28 Thread Haruki Okada (Jira)
[ 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

2023-11-28 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-15919: - Description:

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

2023-11-28 Thread Haruki Okada (Jira)
[ 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

2023-11-28 Thread Haruki Okada (Jira)
[ 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 - >

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

2023-11-28 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-15921: Summary: Flaky test - SaslScramSslEndToEndAuthorizationTest.testAuthentications Key: KAFKA-15921 URL: https://issues.apache.org/jira/browse/KAFKA-15921 Project:

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

2023-11-28 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-15920: Summary: Flaky test - PlaintextConsumerTest.testCoordinatorFailover Key: KAFKA-15920 URL: https://issues.apache.org/jira/browse/KAFKA-15920 Project: Kafka

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

2023-11-28 Thread Haruki Okada (Jira)
[ 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

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

2023-11-28 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-15919: Summary: Flaky test - BrokerLifecycleManagerTest.testAlwaysSendsAccumulatedOfflineDirs Key: KAFKA-15919 URL: https://issues.apache.org/jira/browse/KAFKA-15919

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

2023-11-28 Thread Haruki Okada (Jira)
[ 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

2023-11-28 Thread Haruki Okada (Jira)
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

2023-11-28 Thread Haruki Okada (Jira)
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

2023-11-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1778#comment-1778 ] Haruki Okada commented on KAFKA-15609: -- I added

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

2023-11-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

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

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

2023-11-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782194#comment-17782194 ] Haruki Okada commented on KAFKA-15609: -- [~divijvaidya] Right, when we call two mmaps, they will be

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

2023-11-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782202#comment-17782202 ] Haruki Okada commented on KAFKA-15609: -- I validated the MappedByteBuffer behavior with this Java

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

2023-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779956#comment-17779956 ] Haruki Okada commented on KAFKA-15688: -- > Is it possible to add such a feature to Kafka so that it

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

2023-10-16 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775965#comment-17775965 ] Haruki Okada commented on KAFKA-15609: -- > is the OS intelligent enough to understand that it should

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

2023-10-09 Thread Haruki Okada (Jira)
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:

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

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

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

2023-08-23 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758026#comment-17758026 ] Haruki Okada commented on KAFKA-15391: -- For this issue, we may need to swallow NoSuchFileException

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

2023-08-23 Thread Haruki Okada (Jira)
[ 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

2023-08-22 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757792#comment-17757792 ] Haruki Okada commented on KAFKA-15391: -- May I take this ticket? I'm interested since this issue

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

2023-08-22 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757442#comment-17757442 ] Haruki Okada commented on KAFKA-15391: -- I see, understood. Thanks > Delete topic may lead to

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

2023-08-22 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2023-08-22 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757388#comment-17757388 ] Haruki Okada commented on KAFKA-15391: -- Related? https://issues.apache.org/jira/browse/KAFKA-13403

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

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

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

2023-08-18 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755904#comment-17755904 ] Haruki Okada commented on KAFKA-15046: -- I submitted a patch

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

2023-08-18 Thread Haruki Okada (Jira)
[ 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

2023-08-18 Thread Haruki Okada (Jira)
[ 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

2023-08-18 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755898#comment-17755898 ] Haruki Okada commented on KAFKA-15046: -- After dug into the fsync call paths in detail, I summarized

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

2023-08-16 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755351#comment-17755351 ] Haruki Okada edited comment on KAFKA-15046 at 8/17/23 4:09 AM: --- [~junrao]

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

2023-08-16 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755351#comment-17755351 ] Haruki Okada edited comment on KAFKA-15046 at 8/17/23 4:08 AM: --- [~junrao]

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

2023-08-16 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755351#comment-17755351 ] Haruki Okada commented on KAFKA-15046: -- [~junrao] Hi, sorry for the late response. Thanks for your

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

2023-07-13 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742830#comment-17742830 ] Haruki Okada commented on KAFKA-15185: -- FYI: maybe duplicated with

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

2023-06-06 Thread Haruki Okada (Jira)
[ 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

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

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

2023-06-05 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729561#comment-17729561 ] Haruki Okada commented on KAFKA-15046: -- I see, thank you for pointing out. Hmm, now I agree with

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

2023-06-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728551#comment-17728551 ] Haruki Okada edited comment on KAFKA-15046 at 6/2/23 7:19 AM: -- [~showuon] 

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728551#comment-17728551 ] Haruki Okada commented on KAFKA-15046: -- [~showuon]  Maybe I linked wrong file. What I thought is

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728515#comment-17728515 ] Haruki Okada edited comment on KAFKA-15046 at 6/2/23 4:01 AM: -- Yeah,

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728515#comment-17728515 ] Haruki Okada commented on KAFKA-15046: -- Yeah, io_uring is promising. However it only works with

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728515#comment-17728515 ] Haruki Okada edited comment on KAFKA-15046 at 6/2/23 12:01 AM: --- Yeah,

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

2023-06-01 Thread Haruki Okada (Jira)
[ 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! **

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728266#comment-17728266 ] Haruki Okada edited comment on KAFKA-15046 at 6/1/23 8:39 AM: -- Hm, when I

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728266#comment-17728266 ] Haruki Okada commented on KAFKA-15046: -- Hm, when I dug into further this, I noticed there's another

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

2023-06-01 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728262#comment-17728262 ] Haruki Okada commented on KAFKA-15046: -- Oh I haven't noticed there's another ticket and already the

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

2023-06-01 Thread Haruki Okada (Jira)
[ 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! **

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

2023-05-31 Thread Haruki Okada (Jira)
[ 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! **

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

2023-05-31 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728214#comment-17728214 ] Haruki Okada commented on KAFKA-15046: -- If the suggestion (stop fsync-ing) makes sense, I'm happy

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

2023-05-31 Thread Haruki Okada (Jira)
[ 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! **

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

2023-05-31 Thread Haruki Okada (Jira)
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:

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

2023-02-23 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693013#comment-17693013 ] Haruki Okada commented on KAFKA-14757: -- Possibly related:

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

2022-12-06 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644055#comment-17644055 ] Haruki Okada commented on KAFKA-14445: -- [~kirktrue] Oh I was not aware of KAFKA-14317. Thanks.  

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

2022-12-06 Thread Haruki Okada (Jira)
[ 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

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

2022-12-06 Thread Haruki Okada (Jira)
[ 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

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

2022-12-06 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643768#comment-17643768 ] Haruki Okada commented on KAFKA-14445: -- If the suggestion makes sense, we're happy to send a patch.

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

2022-12-06 Thread Haruki Okada (Jira)
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

2022-07-14 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566872#comment-17566872 ] Haruki Okada commented on KAFKA-13572: -- We experienced similar phenomenon in our Kafka cluster and

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

2022-04-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527800#comment-17527800 ] Haruki Okada edited comment on KAFKA-13403 at 4/26/22 7:35 AM: --- [~showuon]

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

2022-04-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527961#comment-17527961 ] Haruki Okada commented on KAFKA-13855: -- H-mm sorry, sounds like I just overstepped. Yeah, seems we

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

2022-04-25 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527800#comment-17527800 ] Haruki Okada commented on KAFKA-13403: -- [~showuon] Hi, could you help reviewing the PR

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

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

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

2022-03-09 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503911#comment-17503911 ] Haruki Okada edited comment on KAFKA-10690 at 3/10/22, 12:14 AM: - Thanks

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

2022-03-09 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503911#comment-17503911 ] Haruki Okada commented on KAFKA-10690: -- Thanks for the comment.    [~showuon]    > Are you sure

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada reassigned KAFKA-13403: Assignee: Haruki Okada > KafkaServer crashes when deleting topics due to the race in log

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

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

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434630#comment-17434630 ] Haruki Okada edited comment on KAFKA-13403 at 10/27/21, 1:49 AM: -

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

2021-10-26 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434630#comment-17434630 ] Haruki Okada commented on KAFKA-13403: -- [~showuon] Already working on it? or may I. > KafkaServer

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

2021-10-25 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-13403: - Description: h2. Environment * OS: CentOS Linux release 7.6 * Kafka version: 2.4.1 * **

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

2021-10-25 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-13403: Summary: KafkaServer crashes when deleting topics due to the race in log deletion Key: KAFKA-13403 URL: https://issues.apache.org/jira/browse/KAFKA-13403 Project:

[jira] [Commented] (KAFKA-13218) kafka deleted unexpired message unexpectedly

2021-08-19 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401943#comment-17401943 ] Haruki Okada commented on KAFKA-13218: -- One possible cause I can imagine is because logs are rolled

[jira] [Commented] (KAFKA-9648) kafka server should resize backlog when create serversocket

2021-07-22 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17385313#comment-17385313 ] Haruki Okada commented on KAFKA-9648: - [~flashmouse] Hi, I proposed a new KIP regarding this.

[jira] [Comment Edited] (KAFKA-9648) kafka server should resize backlog when create serversocket

2021-07-12 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379515#comment-17379515 ] Haruki Okada edited comment on KAFKA-9648 at 7/13/21, 2:05 AM: --- Hi. We

[jira] [Commented] (KAFKA-9648) kafka server should resize backlog when create serversocket

2021-07-12 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379515#comment-17379515 ] Haruki Okada commented on KAFKA-9648: - Hi. We operate a Kafka cluster in our company which has

[jira] [Commented] (KAFKA-12261) Splitting partition causes message loss for consumers with auto.offset.reset=latest

2021-02-20 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287615#comment-17287615 ] Haruki Okada commented on KAFKA-12261: -- I see, thank you. Seems I don't have permission to set the

[jira] [Commented] (KAFKA-12261) Splitting partition causes message loss for consumers with auto.offset.reset=latest

2021-02-18 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286901#comment-17286901 ] Haruki Okada commented on KAFKA-12261: -- Yeah, actually I've reconsidered about that and changed the

[jira] [Updated] (KAFKA-12261) Splitting partition causes message loss for consumers with auto.offset.reset=latest

2021-02-18 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-12261: - Description: As of now, auto.offset.reset of ConsumerConfig is "latest" by default.   This

[jira] [Updated] (KAFKA-12261) Splitting partition causes message loss for consumers with auto.offset.reset=latest

2021-02-02 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-12261: - Description: As of now, auto.offset.reset of ConsumerConfig is "latest" by default.   This

[jira] [Created] (KAFKA-12261) auto.offset.reset should be earliest by default

2021-01-31 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-12261: Summary: auto.offset.reset should be earliest by default Key: KAFKA-12261 URL: https://issues.apache.org/jira/browse/KAFKA-12261 Project: Kafka Issue Type:

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

2020-11-05 Thread Haruki Okada (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haruki Okada updated KAFKA-10690: - Summary: Produce-response delay caused by lagging replica fetch which affects in-sync one

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

2020-11-05 Thread Haruki Okada (Jira)
Haruki Okada created KAFKA-10690: Summary: Produce-response delay caused by lagging replica fetch which blocks in-sync one Key: KAFKA-10690 URL: https://issues.apache.org/jira/browse/KAFKA-10690

  1   2   >