[jira] [Assigned] (KAFKA-12715) ACL authentication, Host field support IP network segment

[ https://issues.apache.org/jira/browse/KAFKA-12715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12715: -- Assignee: loboxu > ACL authentication, Host field support IP network segment > --

[jira] [Assigned] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

[ https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12773: -- Assignee: loboxu > Use UncheckedIOException when wrapping IOException > -

[jira] [Commented] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

[ https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349615#comment-17349615 ] loboxu commented on KAFKA-12773: [~jagsancio] , Is there a more detailed description of

[jira] [Assigned] (KAFKA-12333) KafkaMetadataLog and MockLock should validate that appended epochs are monotonically

[ https://issues.apache.org/jira/browse/KAFKA-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12333: -- Assignee: loboxu > KafkaMetadataLog and MockLock should validate that appended epochs are > monotoni

[jira] [Commented] (KAFKA-12801) High CPU load after restarting brokers subsequent to quorum loss

[ https://issues.apache.org/jira/browse/KAFKA-12801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349631#comment-17349631 ] loboxu commented on KAFKA-12801: Let me try to repeat the error > High CPU load after r

[jira] [Commented] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

[ https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349920#comment-17349920 ] loboxu commented on KAFKA-12773: All right, I'll take it > Use UncheckedIOException whe

[jira] [Comment Edited] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

[ https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349920#comment-17349920 ] loboxu edited comment on KAFKA-12773 at 5/23/21, 5:38 AM: -- Ther

[jira] [Commented] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

[ https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350212#comment-17350212 ] loboxu commented on KAFKA-12773: ok > Use UncheckedIOException when wrapping IOExceptio

[jira] [Commented] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

[ https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350274#comment-17350274 ] loboxu commented on KAFKA-12773: [~jagsancio]  Could you please tell me the name of you

[jira] [Assigned] (KAFKA-12461) Extend LogManager to cover the metadata topic

[ https://issues.apache.org/jira/browse/KAFKA-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12461: -- Assignee: loboxu > Extend LogManager to cover the metadata topic > --

[jira] [Commented] (KAFKA-12333) KafkaMetadataLog and MockLock should validate that appended epochs are monotonically

[ https://issues.apache.org/jira/browse/KAFKA-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350413#comment-17350413 ] loboxu commented on KAFKA-12333: [~jsancio] The problem seems to have been fixed, right?

[jira] [Assigned] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-10900: -- Assignee: loboxu > Add metrics enumerated in KIP-630 > - > >

[jira] [Assigned] (KAFKA-12461) Extend LogManager to cover the metadata topic

[ https://issues.apache.org/jira/browse/KAFKA-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12461: -- Assignee: (was: loboxu) > Extend LogManager to cover the metadata topic > ---

[jira] [Assigned] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12243: -- Assignee: loboxu > Add toString methods to some of the classes introduced by this Epic >

[jira] [Commented] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351587#comment-17351587 ] loboxu commented on KAFKA-12243: [~jsancio] ,Is there a more detailed description of thi

[jira] [Assigned] (KAFKA-12545) Integrate snapshot in the shell tool

[ https://issues.apache.org/jira/browse/KAFKA-12545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12545: -- Assignee: loboxu > Integrate snapshot in the shell tool > > >

[jira] [Commented] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353920#comment-17353920 ] loboxu commented on KAFKA-10900: [~showuon] I have received the Jire. May I ask whether

[jira] [Commented] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355728#comment-17355728 ] loboxu commented on KAFKA-10900: [~jagsancio]  Can you give me some guidance? Show me wh

[jira] [Comment Edited] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355728#comment-17355728 ] loboxu edited comment on KAFKA-10900 at 6/2/21, 3:04 PM: - [~jags

[jira] [Comment Edited] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355728#comment-17355728 ] loboxu edited comment on KAFKA-10900 at 6/2/21, 3:11 PM: - [~jags

[jira] [Comment Edited] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355728#comment-17355728 ] loboxu edited comment on KAFKA-10900 at 6/2/21, 3:52 PM: - [~jags

[jira] [Commented] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election

[ https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356061#comment-17356061 ] loboxu commented on KAFKA-9220: --- [~akumar] Have you started work yet? If not, I can pick th

[jira] [Assigned] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election

[ https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-9220: - Assignee: loboxu > TimeoutException when using kafka-preferred-replica-election > --

[jira] [Assigned] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election

[ https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-9220: - Assignee: (was: loboxu) > TimeoutException when using kafka-preferred-replica-election > ---

[jira] [Comment Edited] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election

[ https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356061#comment-17356061 ] loboxu edited comment on KAFKA-9220 at 6/3/21, 7:49 AM: [~mark606

[jira] [Created] (KAFKA-12885) Add the --timeout property to kafka-leader-election.sh

loboxu created KAFKA-12885: -- Summary: Add the --timeout property to kafka-leader-election.sh Key: KAFKA-12885 URL: https://issues.apache.org/jira/browse/KAFKA-12885 Project: Kafka Issue Type: Improv

[jira] [Commented] (KAFKA-12885) Add the --timeout property to kafka-leader-election.sh

[ https://issues.apache.org/jira/browse/KAFKA-12885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356286#comment-17356286 ] loboxu commented on KAFKA-12885: [~showuon]  [~jagsancio] Can you help me check it? Is i

[jira] [Updated] (KAFKA-12885) Add the --timeout property to kafka-leader-election.sh

[ https://issues.apache.org/jira/browse/KAFKA-12885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu updated KAFKA-12885: --- Description: https://issues.apache.org/jira/browse/KAFKA-9220 mentions kafka-preferred-replica-election.sh

[jira] [Assigned] (KAFKA-12844) KIP-740 follow up: clean up TaskId

[ https://issues.apache.org/jira/browse/KAFKA-12844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12844: -- Assignee: loboxu > KIP-740 follow up: clean up TaskId > -- > >

[jira] [Assigned] (KAFKA-12844) KIP-740 follow up: clean up TaskId

[ https://issues.apache.org/jira/browse/KAFKA-12844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12844: -- Assignee: (was: loboxu) > KIP-740 follow up: clean up TaskId > --

[jira] [Assigned] (KAFKA-12844) KIP-740 follow up: clean up TaskId

[ https://issues.apache.org/jira/browse/KAFKA-12844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12844: -- Assignee: loboxu > KIP-740 follow up: clean up TaskId > -- > >

[jira] [Assigned] (KAFKA-12843) KIP-740 follow up: clean up TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12843: -- Assignee: loboxu > KIP-740 follow up: clean up TaskMetadata > ---

[jira] [Assigned] (KAFKA-12690) Remove deprecated Producer#sendOffsetsToTransaction

[ https://issues.apache.org/jira/browse/KAFKA-12690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12690: -- Assignee: loboxu > Remove deprecated Producer#sendOffsetsToTransaction >

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

[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12689: -- Assignee: loboxu > Remove deprecated EOS configs > - > >

[jira] [Assigned] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

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

[jira] [Commented] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

[ https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17362484#comment-17362484 ] loboxu commented on KAFKA-12851: I reproduced the error locally and I tried to fix it >

[jira] [Issue Comment Deleted] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

[ https://issues.apache.org/jira/browse/KAFKA-12851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu updated KAFKA-12851: --- Comment: was deleted (was: I reproduced the error locally and I tried to fix it) > Flaky Test RaftEventSimu

[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=17365914#comment-17365914 ] loboxu commented on KAFKA-12689: Thank you very much for reminding me. I know what I sho

[jira] [Issue Comment Deleted] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu updated KAFKA-10900: --- Comment: was deleted (was: [~jagsancio]  Can you give me some guidance? Where the metrics are added in the

[jira] [Assigned] (KAFKA-12851) Flaky Test RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable

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

[jira] [Assigned] (KAFKA-12333) KafkaMetadataLog and MockLock should validate that appended epochs are monotonically

[ https://issues.apache.org/jira/browse/KAFKA-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12333: -- Assignee: (was: loboxu) > KafkaMetadataLog and MockLock should validate that appended epochs are

[jira] [Assigned] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12243: -- Assignee: loboxu > Add toString methods to some of the classes introduced by this Epic >

[jira] [Assigned] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12243: -- Assignee: (was: loboxu) > Add toString methods to some of the classes introduced by this Epic > -

[jira] [Assigned] (KAFKA-12932) Interfaces for SnapshotReader and SnapshotWriter

[ https://issues.apache.org/jira/browse/KAFKA-12932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12932: -- Assignee: loboxu > Interfaces for SnapshotReader and SnapshotWriter > ---

[jira] [Assigned] (KAFKA-10310) Kafka Raft Snapshot

[ https://issues.apache.org/jira/browse/KAFKA-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-10310: -- Assignee: loboxu (was: Jose Armando Garcia Sancio) > Kafka Raft Snapshot > --- > >

[jira] [Issue Comment Deleted] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu updated KAFKA-12243: --- Comment: was deleted (was: [~jsancio] ,Is there a more detailed description of this problem. What classes n

[jira] [Assigned] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

[ https://issues.apache.org/jira/browse/KAFKA-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12243: -- Assignee: (was: loboxu) > Add toString methods to some of the classes introduced by this Epic > -

[jira] [Updated] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu updated KAFKA-10900: --- Description: KIP-630 enumerates a few metrics. Makes sure that those metrics are implemented.   |kafka.cont

[jira] [Assigned] (KAFKA-13016) Interpret snapshot header version to correctly parse the snapshot

[ https://issues.apache.org/jira/browse/KAFKA-13016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-13016: -- Assignee: loboxu > Interpret snapshot header version to correctly parse the snapshot > --

[jira] [Assigned] (KAFKA-12956) Validate the snapshot id when the state machine freeze a snapshot

[ https://issues.apache.org/jira/browse/KAFKA-12956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-12956: -- Assignee: loboxu > Validate the snapshot id when the state machine freeze a snapshot > --

[jira] [Assigned] (KAFKA-13349) Allow Iterator.remove on KeyValueIterator

[ https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loboxu reassigned KAFKA-13349: -- Assignee: loboxu (was: Bartłomiej Stachura) > Allow Iterator.remove on KeyValueIterator > --

[jira] [Commented] (KAFKA-13016) Interpret snapshot header version to correctly parse the snapshot

[ https://issues.apache.org/jira/browse/KAFKA-13016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452377#comment-17452377 ] loboxu commented on KAFKA-13016: [~Niket Goel] Is there a more detailed description of t

[jira] [Commented] (KAFKA-10900) Add metrics enumerated in KIP-630

[ https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452728#comment-17452728 ] loboxu commented on KAFKA-10900: [~jagsancio] The PR has been submitted here, and it see