Apache Kafka® running on Kubernetes
This report summarizes scanner evidence for strimzi/strimzi-kafka-operator, a Java project with 5,966 GitHub stars. SynthScan examined 550,502 lines of code across 2188 source files, recording 89 pattern matches distributed across 10 syntactic categories. The legacy adjusted pattern signal is 0.5 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 70 finding(s).
Are imports declared and package/API names verified? 12 finding(s).
Are wrappers, guards, and repeated structures necessary? 10 finding(s).
Which changes need focused human review? 89 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 89 distinct pattern matches across 10 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …c/test/resources/cruisecontrol/user-tasks-failure.json | 2 | "stackTrace": "java.lang.IllegalStateException: Error happened in fetching response for task 9730e4fb-ea41-4e2d-b053-9 | CODE |
| CRITICAL | …test/resources/cruisecontrol/topic-config-failure.json | 2 | "stackTrace": "java.util.concurrent.ExecutionException: com.linkedin.kafka.cruisecontrol.exception.KafkaCruiseControlE | CODE |
| CRITICAL | …/java/io/strimzi/operator/common/ca/CertManagerCa.java | 339 | return new io.fabric8.kubernetes.api.model.Duration(Duration.ofDays(days)); | CODE |
| CRITICAL | …r/assembly/CruiseControlJSON/CC-State-fetch-error.json | 1 | {"errorMessage":"Error processing GET request '/state' due to: 'Cruise Control server is unreachable.'","stackTrace":"ja | CODE |
| CRITICAL | …trolJSON/CC-Rebalance-NotEnoughValidWindows-error.json | 1 | {"errorMessage":"Error processing POST request \u0027/rebalance\u0027 due to: \u0027com.linkedin.kafka.cruisecontrol.exc | CODE |
| CRITICAL | …ly/CruiseControlJSON/CC-Rebalance-bad-goals-error.json | 1 | {"errorMessage":"Error processing POST request \u0027/rebalance\u0027 due to: \u0027java.lang.IllegalArgumentException: | CODE |
| CRITICAL | …or/assembly/CruiseControlJSON/CC-Broker-not-exist.json | 3 | "stackTrace": "java.util.concurrent.ExecutionException: com.linkedin.kafka.cruisecontrol.exception.KafkaCruiseControlE | CODE |
| CRITICAL | …CruiseControlJSON/CC-User-task-status-fetch-error.json | 1 | {"errorMessage":"Error processing GET request \u0027/user_tasks\u0027 due to: \u0027Error happened in fetching response | CODE |
| CRITICAL | …zi/operator/cluster/model/AuthenticationUtilsTest.java | 132 | // like this new org.apache.kafka.common.security.JaasConfig(); | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | kafka-versions.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| MEDIUM | packaging/examples/security/cert-manager/issuers.yaml | 1 | # This file contains the definitions for the self-signed issuer that is used to issue the root certificates for the Clie | COMMENT |
| MEDIUM | …/kafka-based/kafka/cruise-control-scripts/tls_utils.sh | 5 | # This file contains bash functions loaded and used by other scripts | COMMENT |
| MEDIUM | …esources/kafka-versions/kafka-versions-duplicates.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| MEDIUM | …est/resources/kafka-versions/kafka-versions-valid.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| MEDIUM | …sources/kafka-versions/kafka-versions-twodefaults.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| MEDIUM | …resources/kafka-versions/kafka-versions-nodefault.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 386 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 530 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 591 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 636 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 683 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 728 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 773 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 819 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 864 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …operator/cluster/model/KafkaConnectDockerfileTest.java | 908 | "# This file is automatically generated by the Strimzi Cluster Operator\n" + | CODE |
| MEDIUM | …tor/cluster/model/KafkaBrokerConfigurationBuilder.java | 1024 | writer.println("# This file is automatically generated by the Strimzi Cluster Operator"); | CODE |
| MEDIUM | …ator/cluster/model/KafkaAgentConfigurationBuilder.java | 87 | writer.println("# This file is automatically generated by the Strimzi Cluster Operator"); | CODE |
| MEDIUM | …tor/cluster/model/KafkaBridgeConfigurationBuilder.java | 416 | writer.println("# This file is automatically generated by the Strimzi Cluster Operator"); | CODE |
| MEDIUM | …mzi/operator/cluster/model/KafkaConnectDockerfile.java | 491 | writer.println("# This file is automatically generated by the Strimzi Cluster Operator"); | CODE |
| MEDIUM | …or/cluster/model/KafkaConnectConfigurationBuilder.java | 428 | writer.println("# This file is automatically generated by the Strimzi Cluster Operator"); | CODE |
| MEDIUM | examples/security/cert-manager/issuers.yaml | 1 | # This file contains the definitions for the self-signed issuer that is used to issue the root certificates for the Clie | COMMENT |
| MEDIUM | .github/workflows/github-actions-integration.yml | 381 | # Create a temporary event file with the performance_dir input | COMMENT |
| MEDIUM | …hub/actions/systemtests/generate-matrix/pipelines.yaml | 2 | # This file contains predefined pipelines used by generate-matrix action | COMMENT |
| MEDIUM | .azure/scripts/setup-kind.sh | 272 | # Create the KIND cluster | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …java/io/strimzi/operator/common/ca/InternalCaTest.java | 0 | -----begin certificate----- miidlzccan+gawibagiuemvt2m8ynfylntb16p2/osfqvhewdqyjkozihvcnaqel bqawwjelmakga1uebhmcqvuxeza | STRING |
| HIGH | …uster/operator/assembly/KafkaAssemblyOperatorTest.java | 0 | -----begin certificate----- miidlzccan+gawibagiuemvt2m8ynfylntb16p2/osfqvhewdqyjkozihvcnaqel bqawwjelmakga1uebhmcqvuxeza | STRING |
| HIGH | …rator/assembly/KafkaAssemblyOperatorWithKRaftTest.java | 0 | -----begin certificate----- miidlzccan+gawibagiuemvt2m8ynfylntb16p2/osfqvhewdqyjkozihvcnaqel bqawwjelmakga1uebhmcqvuxeza | STRING |
| HIGH | …o/strimzi/operator/common/ca/CertificateUtilsTest.java | 0 | -----begin certificate----- miidhjccam6gawibagijanzx2ppcygmlma0gcsqgsib3dqebcwuamfcxczajbgnv baytalhymruwewydvqqhdaxezwz | STRING |
| HIGH | …o/strimzi/operator/common/operator/MockCertIssuer.java | 0 | -----begin certificate----- miidhjccam6gawibagijanzx2ppcygmlma0gcsqgsib3dqebcwuamfcxczajbgnv baytalhymruwewydvqqhdaxezwz | STRING |
| HIGH | …st/java/io/strimzi/operator/cluster/ResourceUtils.java | 0 | -----begin certificate----- miidhjccam6gawibagijanzx2ppcygmlma0gcsqgsib3dqebcwuamfcxczajbgnv baytalhymruwewydvqqhdaxezwz | STRING |
| HIGH | …r/assembly/KafkaConnectAssemblyOperatorPodSetTest.java | 0 | -----begin certificate----- miidhjccam6gawibagijanzx2ppcygmlma0gcsqgsib3dqebcwuamfcxczajbgnv baytalhymruwewydvqqhdaxezwz | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | kafka-versions.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| LOW | …aging/install/drain-cleaner/kubernetes/040-Secret.yaml | 1 | # | COMMENT |
| LOW | …g/helm-charts/helm3/strimzi-kafka-operator/values.yaml | 81 | COMMENT | |
| LOW | …g/helm-charts/helm3/strimzi-kafka-operator/values.yaml | 101 | # For ingress we permit access to the metrics endpoint | COMMENT |
| LOW | …emtest/src/test/resources/upgrade/BundleDowngrade.yaml | 1 | # --- Structure --- | COMMENT |
| LOW | …emtest/src/test/resources/upgrade/BundleDowngrade.yaml | 21 | # continuousClientsMessages: int - message count sent during upgrade | COMMENT |
| LOW | systemtest/src/test/resources/upgrade/OlmUpgrade.yaml | 1 | # --- Structure --- | COMMENT |
| LOW | …stemtest/src/test/resources/upgrade/BundleUpgrade.yaml | 1 | # --- Structure --- | COMMENT |
| LOW | …stemtest/src/test/resources/upgrade/BundleUpgrade.yaml | 21 | # client: | COMMENT |
| LOW | …st/resources/connect-build/connect-build-template.yaml | 21 | trustedCertificates: | COMMENT |
| LOW | …st/resources/connect-build/connect-build-template.yaml | 41 | # runAsGroup: 1000 | COMMENT |
| LOW | …test/src/test/resources/cert-manager/cert-manager.yaml | 1 | # Copyright 2022 The cert-manager Authors. | COMMENT |
| LOW | …test/src/test/resources/cert-manager/cert-manager.yaml | 13181 | nodeSelector: | COMMENT |
| LOW | …/kafka-based/kafka/cruise-control-scripts/tls_utils.sh | 21 | # shellcheck disable=SC2086 | COMMENT |
| LOW | …/kafka-based/kafka/cruise-control-scripts/tls_utils.sh | 41 | # Parameters: | COMMENT |
| LOW | install/drain-cleaner/kubernetes/040-Secret.yaml | 1 | # | COMMENT |
| LOW | …rimzi/operator/common/model/ValidationVisitorTest.java | 41 | //assertThat(warningMessages, hasItem("In resource Kafka(testnamespace/testname) in API version kafka.strimzi.io | COMMENT |
| LOW | …esources/kafka-versions/kafka-versions-duplicates.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| LOW | …est/resources/kafka-versions/kafka-versions-valid.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| LOW | …sources/kafka-versions/kafka-versions-twodefaults.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| LOW | …resources/kafka-versions/kafka-versions-nodefault.yaml | 1 | # This file is used to specify the versions of Kafka which will be built | COMMENT |
| LOW | .github/workflows/codeql-analysis.yml | 1 | # For most projects, this workflow file will not need changing; you simply need | COMMENT |
| LOW | …hub/actions/systemtests/generate-matrix/pipelines.yaml | 1 | #################################################################################################### | COMMENT |
| LOW | .azure/build-pipeline.yaml | 61 | # - stage: push_containers | COMMENT |
| LOW | .azure/build-pipeline.yaml | 81 | # - stage: public_docs | COMMENT |
| LOW | .azure/build-pipeline.yaml | 101 | # displayName: Deploy Java artifacts | COMMENT |
| LOW | .azure/scripts/setup-kind.sh | 381 | # update insecure registries | COMMENT |
| LOW | helm-charts/helm3/strimzi-kafka-operator/values.yaml | 81 | # | COMMENT |
| LOW | helm-charts/helm3/strimzi-kafka-operator/values.yaml | 101 | - ports: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | packaging/examples/security/cert-manager/kafka.yaml | 73 | caCertRef: # Optionally, you can use trust-manager to isolate the CA certificate into a separate Secret or sync it | CODE |
| MEDIUM | packaging/examples/security/cert-manager/kafka.yaml | 84 | caCertRef: # Optionally, you can use trust-manager to isolate the CA certificate into a separate Secret or sync it | CODE |
| MEDIUM | examples/security/cert-manager/kafka.yaml | 73 | caCertRef: # Optionally, you can use trust-manager to isolate the CA certificate into a separate Secret or sync it | CODE |
| MEDIUM | examples/security/cert-manager/kafka.yaml | 84 | caCertRef: # Optionally, you can use trust-manager to isolate the CA certificate into a separate Secret or sync it | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …st/performance/utils/UserOperatorPerformanceUtils.java | 377 | // Step 1: Create N users to establish load | COMMENT |
| LOW⚡ | …st/performance/utils/UserOperatorPerformanceUtils.java | 383 | // Step 2: Measure latency of individual modifications under this load | COMMENT |
| LOW | …cluster/operator/assembly/StrimziPodSetController.java | 343 | // owner reference again, we need to check if the PodSet is being deleted and if it is, we leave it to | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …st/performance/utils/UserOperatorPerformanceUtils.java | 377 | // Step 1: Create N users to establish load | COMMENT |
| LOW⚡ | …st/performance/utils/UserOperatorPerformanceUtils.java | 383 | // Step 2: Measure latency of individual modifications under this load | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | docker-images/artifacts/build.sh | 78 | # Check if there is an existing binary file and checksum it against the checksum listed in the kafka-versions fi | COMMENT |
| LOW | .github/actions/utils/set-defaults/action.yml | 19 | # Check if we're in a pull request context | COMMENT |
| LOW | .azure/scripts/setup-kind.sh | 303 | # Check if using Podman and warn the user | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …rc/test/resources/connect-build/build-connect-image.sh | 9 | function getLatestKafkaMavenVersionFromYAML() { | CODE |
| LOW | …actions/systemtests/run-perf-report/generate-report.js | 38 | function findTimestampedResultsDir(baseDir) { | CODE |
| LOW | …actions/systemtests/run-perf-report/generate-report.js | 338 | function generatePerformanceReport(perfDir, core) { | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …stemtest/src/test/resources/oauth2/internal_realm.json | 33 | "email": "admin@example.com", | CODE |
| LOW | …/src/test/java/io/strimzi/operator/topic/MainTest.java | 51 | "user.key", Util.encodeToBase64("dummy-key"), | CODE |
| LOW | …java/io/strimzi/operator/common/ca/InternalCaTest.java | 218 | clusterCaKeyData.put(InternalCa.CA_KEY, Base64.getEncoder().encodeToString("dummy-key".getBytes())); | STRING |