[jira] [Resolved] (KAFKA-15661) KIP-951: Server side and protocol changes

2023-11-27 Thread Crispin Bernier (Jira) 


 [ 
https://issues.apache.org/jira/browse/KAFKA-15661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Crispin Bernier resolved KAFKA-15661.
-
Resolution: Resolved

> KIP-951: Server side and protocol changes
> -
>
> Key: KAFKA-15661
> URL: https://issues.apache.org/jira/browse/KAFKA-15661
> Project: Kafka
>  Issue Type: Task
>  Components: protocol
>Reporter: Crispin Bernier
>Assignee: Crispin Bernier
>Priority: Major
> Fix For: 3.7.0
>
>
> Server side and protocol changes for implementing KIP-951, passing back the 
> new leader to the client on NOT_LEADER_OR_FOLLOWER errors for fetch and 
> produce requests.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (KAFKA-15661) KIP-951: Server side and protocol changes

2023-10-20 Thread Crispin Bernier (Jira) 
Crispin Bernier created KAFKA-15661:
---

 Summary: KIP-951: Server side and protocol changes
 Key: KAFKA-15661
 URL: https://issues.apache.org/jira/browse/KAFKA-15661
 Project: Kafka
  Issue Type: Task
  Components: protocol
Reporter: Crispin Bernier


Server side and protocol changes for implementing KIP-951, passing back the new 
leader to the client on NOT_LEADER_OR_FOLLOWER errors for fetch and produce 
requests.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (KAFKA-13688) Incorrect metrics in KafkaController for replicasToDeleteCount and ineligibleReplicasToDeleteCount

2022-02-22 Thread Crispin Bernier (Jira) 
Crispin Bernier created KAFKA-13688:
---

 Summary: Incorrect metrics in KafkaController for 
replicasToDeleteCount and ineligibleReplicasToDeleteCount
 Key: KAFKA-13688
 URL: https://issues.apache.org/jira/browse/KAFKA-13688
 Project: Kafka
  Issue Type: Bug
  Components: controller
Reporter: Crispin Bernier


{code:java}
replicasToDeleteCount = if (!isActive) 0 else 
controllerContext.topicsToBeDeleted.map { topic =>  // For each enqueued 
topic, count the number of replicas that are not yet deleted  
controllerContext.replicasForTopic(topic).count { replica =>
controllerContext.replicaState(replica) != ReplicaDeletionSuccessful  }
}.sum

ineligibleReplicasToDeleteCount = if (!isActive) 0 else 
controllerContext.topicsToBeDeleted.map { topic =>  // For each enqueued 
topic, count the number of replicas that are ineligible  
controllerContext.replicasForTopic(topic).count { replica =>
controllerContext.replicaState(replica) == ReplicaDeletionIneligible  }
}.sum {code}
Duplicate replica counts will get ignored in the total sum when the code above 
converts to a set.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)