[GitHub] [kafka] showuon commented on a change in pull request #11225: MINOR; Small optimizations in `ReplicaManager#becomeLeaderOrFollower`

showuon commented on a change in pull request #11225: URL: https://github.com/apache/kafka/pull/11225#discussion_r693322503 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,

[GitHub] [kafka] PhilHardwick opened a new pull request #11248: MINOR: Fix null pointer when getting metric value in MetricsReporter

PhilHardwick opened a new pull request #11248: URL: https://github.com/apache/kafka/pull/11248 The alive stream threads metric relies on the threads field as a monitor object for its synchronized block. When the alive stream threads metric is registered it isn't initialised so any ca

[GitHub] [kafka] PhilHardwick commented on pull request #11248: MINOR: Fix null pointer when getting metric value in MetricsReporter

PhilHardwick commented on pull request #11248: URL: https://github.com/apache/kafka/pull/11248#issuecomment-903093642 Requesting review from @ableegoldman and @wcarlson5 please -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [kafka] rondagostino commented on pull request #11239: KAFKA-13219: BrokerState metric not working for KRaft clusters

rondagostino commented on pull request #11239: URL: https://github.com/apache/kafka/pull/11239#issuecomment-903126406 Thanks, @ijuma. Yeah, the problem was that there were two different ways to get at a state -- only one of which was working -- and it makes sense to eliminate `currentStat

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402624#comment-17402624 ] Tomer Wizman commented on KAFKA-12766: -- Hi Bruno, Sophie, Konstantine, nice e-meeti

[jira] [Created] (KAFKA-13222) Records in newly rolled segment couldn't be fetched by consumer

Zhipeng Liu created KAFKA-13222: --- Summary: Records in newly rolled segment couldn't be fetched by consumer Key: KAFKA-13222 URL: https://issues.apache.org/jira/browse/KAFKA-13222 Project: Kafka

[jira] [Updated] (KAFKA-13222) Records in newly rolled segment couldn't be fetched by consumer

[ https://issues.apache.org/jira/browse/KAFKA-13222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Liu updated KAFKA-13222: Priority: Major (was: Minor) > Records in newly rolled segment couldn't be fetched by consumer >

[jira] [Resolved] (KAFKA-12701) NPE in MetadataRequest when using topic IDs

[ https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming resolved KAFKA-12701. Assignee: Justine Olshan (was: dengziming) Resolution: Fixed > NPE in MetadataRequest when