strimzi-kafka-operator
strimzi-kafka-operator copied to clipboard
Apache Kafka® running on Kubernetes
Currently we've failed to really encapsulate and abstract our certificate handling. What I mean by that is everywhere we pass around a `Secret` which we _happen to know_ contains a...
In PR #6669, the code fixing the counting of the Connect metrics uses a Label selector with the `In` requirement which is currently not supported in the in-parallel developed move...
**Suggestion / Problem** There is no documentation of how to configure SCRAM 512 with mTLS. **Documentation Link** We are using for test the following Kafka configuration, but we cannot create...
**Is your feature request related to a problem? Please describe.** When analyzing out-of-memory problems happening in JVM, it helps to collect and look at the heap dump (see [DBZ-1104](https://issues.redhat.com/browse/DBZ-1104) for...
**Is your feature request related to a problem? Please describe.** At the moment there is no nice way to use secrets for Kafka Connect, which are fetched from cloud key...
**Describe the bug** Strimzi keeps creating k8s kafkatopic manifests for topics that already exist in the cluster. It keeps forgetting it has the kafka topics defined in k8s, sees it...
The `KafkaAssemblyOperator` is currently using a `Date` supplier to provide a `Date` instance where it's needed and allowing more easily the corresponding testing. It's mostly used to check maintenance window...
The tests in `SessionStartupDoesNotBlockMainThreadTest` use detection of the main thread being blocked. Right now, they use system properties to configure `vertx.logger-delegate-factory-class-name` and override the logger to detect it. This seems...
With the current implementation in the `HttpClientUtils` class, a new `HttpClient` instance is created and closed every time. https://github.com/strimzi/strimzi-kafka-operator/blob/main/cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/resource/HttpClientUtils.java#L27 This is mostly used in the Kafka Connect and Cruise Control...
When the number of Kafka replicas is decreased in the Kafka CR the StatefulSet will shutdown the highest numbered brokers. Currently, there is no check to see if these brokers...