Federico Valeri

Add shutdown hook to user and topic operators.

23

This change is required to ensure that Verticle.stop() is called during a clean shutdown, so that watches can be closed and any inflight reconciliation has a chance to complete. I'm...

MM2 PDB maxUnavailable is one when scaling down to zero

2

When scaling MM2 down to zero, its PDB has fixed `maxUnavailable: 1` and this causes warnings when draining the K8s node. ``` # before $ kubectl get po NAME READY...

Improve the operator shutdown hook

5

I did some more investigation on the hanging shutdown issue, and came out with this improved shutdown hook which completely avoids it. The previous version does not cover the scenario...

Add topic replication factor change

2

This change implements the proposal about topic replication factor change. https://github.com/strimzi/proposals/blob/main/066-topic-replication-factor-change.md Documentation will be added in a separate PR. To avoid making the review of new components harder, there is...

[Bug]: Connect's dynamic log level changes are only applied to one worker node

1

### Bug Description If we deploy the following 3-nodes Connect cluster: ```sh $ kubectl get po NAME READY STATUS RESTARTS AGE my-cluster-entity-operator-dbfcd857c-kfz92 3/3 Running 0 25m my-cluster-kafka-0 1/1 Running 0...

Extract Topic Operator's Cruise Control client

9

This is the first step in the direction of having a shared Cruise Control client based on Java HTTP client. For the moment changes are limited to the Topic Operator....

Related to this [PR comment](https://github.com/strimzi/strimzi-kafka-operator/pull/10056#discussion_r1591395028).

### Related problem In #9216, we created additional metrics for requests to external services (Kubernetes and Kafka). These additional metrics are disabled by default, but can be enabled to track...

Document default value for completed.user.task.retention.time.ms

1

This change documents the default value for completed.user.task.retention.time.ms as specified in: https://github.com/linkedin/cruise-control/blob/main/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/config/constants/UserTaskManagerConfig.java#L107

Complete BatchingTopicController refactoring: handler classes

2

### Type of change - Refactoring ### Description This change completes the BatchingTopicController refactoring by introduicing a set of handlers, one for each external system, that host the request logic....