Federico Valeri

Results 23 issues of Federico Valeri

This change fixes the issue caused by the TO-CC race condition during throttled rebalances. The TO reverts dynamic throttled configs set by CC at the topic level because they don't...

topic operator

This change adds the `--remote-log-metadata-decoder` flag to the `kafka-dump-log.sh` tool. This new flag can be used to decode the payload of the `__remote_log_metadata` records produced by the default `RemoteLogMetadataManager`.

tools
tiered-storage

### Type of change - Refactoring ### Description This change completes the TO refactoring by introducing a set of handlers and related tests. Each handler contains the logic used to...

### Type of change Bugfix ### Description The KafkaTopic.status.topicId keeps the old value when the topic is recreated in Kafka while the reconciliation is paused/disabled, or the operator is not...

### Bug Description The KafkaTopic.status.topicId keeps the old value when the topic is recreated in Kafka while the reconciliation is paused/disabled, or the operator is not running. ### Steps to...

bug
help wanted
good-start

### Type of change - Documentation ### Description This patch should close #10722. The challenging task here is to retrieve the `clusterId` from existing volumes. I thought to spin up...

### Bug Description When Kraft disks are already formatted, we have to reuse the previous cluster.id in addition to the --ignore-formatted flag. This is required by the Kafka storage tool...

documentation

According to KIP-950, `remote.log.manager.thread.pool.size` should be marked as deprecated and replaced by two new configurations: `remote.log.manager.copier.thread.pool.size` and `remote.log.manager.expiration.thread.pool.size`.

core
storage
ci-approved
small

### Type of change - Refactoring ### Description This patch removes unnecessary methods from `TopicOperatorUtil` class. Like the Kafka admin and Kubernetes clients, the CC client was designed as a...

needs review
topic operator

### Related problem In Kafka 4.0.0, the `org.apache.kafka.common.metrics.JmxReporter` will still be enabled by default, but the user will need to explicitly add this plugin to the `metric.reporters` property when setting...

enhancement