Executive summary
zio/zio-kafka scores 60 out of 100 and is rated Adequate, while five of its six lenses score higher still: Architecture at 90, Production Readiness at 76, Security and Compliance at 62 and Code Health at 61, all rated Adequate, and Performance at 81, rated Strong.
The score is lower than those five because the weakest lens counts most, and here that is Maturity, which scores 52 and is rated Adequate. Its Architecture documentation dimension scores 2 out of 10, and until that reaches 4, Maturity can't be rated higher than Adequate. The first actions are to resolve the 1 No ADRs found finding(s) in ADR Quality and to record your significant design decisions, and if Maturity rose to 70, the score would rise from 60 to about 65.
70 findings are critical: 66 in Static Analysis (SAST), two in REDACTED Scanning and two in Secrets (history).
Watchdog couldn't measure 7 dimensions in this code, among them Code Coverage, Test Reliability and Internal API Consistency, so they are left out of the score. The product code is 8,811 lines, which would take an estimated 0.1 person-years, around €17,000, to rebuild.
If Maturity rose from 52 to 70, the lowest score rated Strong, the score would rise from 60 to about 65.
New since the last survey: 10 findings
- Cognitive Complexity · ZioKafkaConsumerBenchmark.initialize (cognitive 21) zio-kafka-bench/src/main/scala/zio/kafka/bench/ZioKafkaConsumerBenchmark.scala
- REDACTED Scanning · REDACTED
- Static Analysis (SAST) · REDACTED
- Static Analysis (SAST) · REDACTED
- Static Analysis (SAST) · REDACTED
- Static Analysis (SAST) · REDACTED
- Static Analysis (SAST) · REDACTED
- Static Analysis (SAST) · REDACTED
- Static Analysis (SAST) · REDACTED
- Supply-chain Provenance & Signing · REDACTED
Rebuild cost: about €17,000 · Estimate
| Cost to rebuild | €5,500 to €28,000, for 92 to 291 hours of work, about 0.1 person-years for one engineer |
|---|---|
| Difficulty of the problem | Standard, judged from the kind of software and how it is built. Code that solves a harder problem, such as payments or medical bookings, costs more per line to write. |
| Quality factor | ×0.8 at a score of 60. Better code takes more work to write, so the factor is ×1.0 at a score of 70, lower below it and higher above it. |
| Size | Small: 8,811 lines of product code |
Top priorities
Diagnosis: what the measurements show together
Architecture — module dependency graph
Architecture: which parts of the code depend on which
| uses → | 1 admin.resource | 2 consumer.Consumer | 3 consumer.diagnostics | 4 metrics.MetricInfo | 5 security | 6 admin.AdminClient.AlterConfigOpType | 7 admin.acl | 8 consumer.metrics.ConsumerMetricsObserver | 9 diagnostics | 10 testkit.Kafka | 11 admin.acl.AclOperation | 12 consumer.Consumer.OffsetRetrieval | 13 consumer.metrics | 14 diagnostics.internal | 15 metrics.internal.MetricInfoToZioMetric | 16 producer.metrics | 17 admin.AdminClient | 18 serde | 19 admin | 20 admin.AdminClient.ConfigResourceType | 21 admin.AdminClient.GroupType | 22 consumer.diagnostics.DiagnosticEvent | 23 consumer.internal.RebalanceCoordinator | 24 consumer.internal.RunloopCommand | 25 consumer.diagnostics.DiagnosticEvent.Commit | 26 consumer.internal.Committer | 27 consumer.internal.Runloop | 28 consumer.internal | 29 consumer.fetch | 30 consumer | 31 consumer.Subscription | 32 consumer.internal.SubscriptionState | 33 producer.TransactionalProducer | 34 producer | 35 example | 36 producer.ProducerEvent | 37 producer.ProducerLive | 38 testkit | 39 bench | 40 bench.comparison |
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| 1 admin.resource | ||||||||||||||||||||||||||||||||||||||||
| 2 consumer.Consumer | ||||||||||||||||||||||||||||||||||||||||
| 3 consumer.diagnostics | ||||||||||||||||||||||||||||||||||||||||
| 4 metrics.MetricInfo | ||||||||||||||||||||||||||||||||||||||||
| 5 security | ||||||||||||||||||||||||||||||||||||||||
| 6 admin.AdminClient.AlterConfigOpType | 4 | |||||||||||||||||||||||||||||||||||||||
| 7 admin.acl | 2 | |||||||||||||||||||||||||||||||||||||||
| 8 consumer.metrics.ConsumerMetricsObserver | 1 | |||||||||||||||||||||||||||||||||||||||
| 9 diagnostics | 2 | |||||||||||||||||||||||||||||||||||||||
| 10 testkit.Kafka | 3 | |||||||||||||||||||||||||||||||||||||||
| 11 admin.acl.AclOperation | 16 | |||||||||||||||||||||||||||||||||||||||
| 12 consumer.Consumer.OffsetRetrieval | 6 | 2 | ||||||||||||||||||||||||||||||||||||||
| 13 consumer.metrics | 6 | 1 | 2 | |||||||||||||||||||||||||||||||||||||
| 14 diagnostics.internal | 1 | 1 | ||||||||||||||||||||||||||||||||||||||
| 15 metrics.internal.MetricInfoToZioMetric | 5 | 5 | ||||||||||||||||||||||||||||||||||||||
| 16 producer.metrics | 4 | 1 | ||||||||||||||||||||||||||||||||||||||
| 17 admin.AdminClient | 6 | 8 | 1 | 1 | ||||||||||||||||||||||||||||||||||||
| 18 serde | 1 | |||||||||||||||||||||||||||||||||||||||
| 19 admin | 1 | 1 | 6 | 1 | 35 | |||||||||||||||||||||||||||||||||||
| 20 admin.AdminClient.ConfigResourceType | 6 | |||||||||||||||||||||||||||||||||||||||
| 21 admin.AdminClient.GroupType | 5 | |||||||||||||||||||||||||||||||||||||||
| 22 consumer.diagnostics.DiagnosticEvent | 7 | 2 | 3 | |||||||||||||||||||||||||||||||||||||
| 23 consumer.internal.RebalanceCoordinator | 1 | 2 | 1 | |||||||||||||||||||||||||||||||||||||
| 24 consumer.internal.RunloopCommand | 1 | 2 | 4 | |||||||||||||||||||||||||||||||||||||
| 25 consumer.diagnostics.DiagnosticEvent.Commit | 6 | 3 | ||||||||||||||||||||||||||||||||||||||
| 26 consumer.internal.Committer | 1 | 1 | 1 | |||||||||||||||||||||||||||||||||||||
| 27 consumer.internal.Runloop | 1 | 1 | 4 | 4 | ||||||||||||||||||||||||||||||||||||
| 28 consumer.internal | 3 | 4 | 7 | 2 | 1 | 1 | 2 | 3 | 7 | |||||||||||||||||||||||||||||||
| 29 consumer.fetch | 3 | 3 | 3 | 3 | ||||||||||||||||||||||||||||||||||||
| 30 consumer | 1 | 1 | 4 | 6 | 1 | 16 | 3 | 1 | 1 | |||||||||||||||||||||||||||||||
| 31 consumer.Subscription | 2 | 1 | 3 | |||||||||||||||||||||||||||||||||||||
| 32 consumer.internal.SubscriptionState | 1 | 2 | 1 | |||||||||||||||||||||||||||||||||||||
| 33 producer.TransactionalProducer | 1 | 2 | 3 | |||||||||||||||||||||||||||||||||||||
| 34 producer | 1 | 2 | 3 | 1 | 2 | 3 | 4 | 1 | ||||||||||||||||||||||||||||||||
| 35 example | 3 | 1 | 2 | 1 | ||||||||||||||||||||||||||||||||||||
| 36 producer.ProducerEvent | 1 | 3 | ||||||||||||||||||||||||||||||||||||||
| 37 producer.ProducerLive | 1 | 3 | ||||||||||||||||||||||||||||||||||||||
| 38 testkit | 1 | 1 | 2 | 2 | 1 | 3 | 4 | |||||||||||||||||||||||||||||||||
| 39 bench | 4 | 1 | 3 | |||||||||||||||||||||||||||||||||||||
| 40 bench.comparison | 3 | 1 | 1 | 1 | 1 |
6→17 admin.AdminClient.AlterConfigOpType uses admin.AdminClient part of a loop✕
- Connections
- 4 pairs of types, where a type in admin.AdminClient.AlterConfigOpType uses a type in admin.AdminClient.
- The types involved
zio.kafka.admin.AdminClient.AlterConfigOpType.Append→zio.kafka.admin.AdminClient.AlterConfigOpTypezio.kafka.admin.AdminClient.AlterConfigOpType.Delete→zio.kafka.admin.AdminClient.AlterConfigOpTypezio.kafka.admin.AdminClient.AlterConfigOpType.Set→zio.kafka.admin.AdminClient.AlterConfigOpTypezio.kafka.admin.AdminClient.AlterConfigOpType.Subtract→zio.kafka.admin.AdminClient.AlterConfigOpType
- Direction
- admin.AdminClient.AlterConfigOpType uses admin.AdminClient, so a change to admin.AdminClient can break admin.AdminClient.AlterConfigOpType, while a change to admin.AdminClient.AlterConfigOpType can't break admin.AdminClient.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
7→1 admin.acl uses admin.resource✕
- Connections
- 2 pairs of types, where a type in admin.acl uses a type in admin.resource.
- The types involved
zio.kafka.admin.acl.AclBinding→zio.kafka.admin.resource.ResourcePatternzio.kafka.admin.acl.AclBindingFilter→zio.kafka.admin.resource.ResourcePatternFilter
- Direction
- admin.acl uses admin.resource, so a change to admin.resource can break admin.acl, while a change to admin.acl can't break admin.resource.
- Position
- Below the diagonal: admin.acl uses a module listed above it, which is the healthy direction.
8→13 consumer.metrics.ConsumerMetricsObserver uses consumer.metrics part of a loop✕
- Connections
- 1 pair of types, where a type in consumer.metrics.ConsumerMetricsObserver uses a type in consumer.metrics.
- The types involved
zio.kafka.consumer.metrics.ConsumerMetricsObserver.NoOp→zio.kafka.consumer.metrics.ConsumerMetricsObserver
- Direction
- consumer.metrics.ConsumerMetricsObserver uses consumer.metrics, so a change to consumer.metrics can break consumer.metrics.ConsumerMetricsObserver, while a change to consumer.metrics.ConsumerMetricsObserver can't break consumer.metrics.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
9→3 diagnostics uses consumer.diagnostics✕
- Connections
- 2 pairs of types, where a type in diagnostics uses a type in consumer.diagnostics.
- The types involved
zio.kafka.diagnostics.QueuingDiagnostics→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.diagnostics.SlidingDiagnostics→zio.kafka.consumer.diagnostics.DiagnosticEvent
- Direction
- diagnostics uses consumer.diagnostics, so a change to consumer.diagnostics can break diagnostics, while a change to diagnostics can't break consumer.diagnostics.
- Position
- Below the diagonal: diagnostics uses a module listed above it, which is the healthy direction.
10→38 testkit.Kafka uses testkit part of a loop✕
- Connections
- 3 pairs of types, where a type in testkit.Kafka uses a type in testkit.
- The types involved
zio.kafka.testkit.Kafka.DefaultLocal→zio.kafka.testkit.Kafkazio.kafka.testkit.Kafka.EmbeddedKafkaService→zio.kafka.testkit.Kafkazio.kafka.testkit.Kafka.Sasl→zio.kafka.testkit.Kafka
- Direction
- testkit.Kafka uses testkit, so a change to testkit can break testkit.Kafka, while a change to testkit.Kafka can't break testkit.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
11→7 admin.acl.AclOperation uses admin.acl✕
- Connections
- 16 pairs of types, where a type in admin.acl.AclOperation uses a type in admin.acl.
- The types involved
zio.kafka.admin.acl.AclOperation.All→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Alter→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.AlterConfigs→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Any→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.ClusterAction→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Create→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.CreateTokens→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Delete→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Describe→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.DescribeConfigs→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.DescribeTokens→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.IdempotentWrite→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Read→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.TwoPhaseCommit→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Unknown→zio.kafka.admin.acl.AclOperationzio.kafka.admin.acl.AclOperation.Write→zio.kafka.admin.acl.AclOperation
- Direction
- admin.acl.AclOperation uses admin.acl, so a change to admin.acl can break admin.acl.AclOperation, while a change to admin.acl.AclOperation can't break admin.acl.
- Position
- Below the diagonal: admin.acl.AclOperation uses a module listed above it, which is the healthy direction.
12→2 consumer.Consumer.OffsetRetrieval uses consumer.Consumer✕
- Connections
- 6 pairs of types, where a type in consumer.Consumer.OffsetRetrieval uses a type in consumer.Consumer.
- The types involved
zio.kafka.consumer.Consumer.OffsetRetrieval.Auto→zio.kafka.consumer.Consumer.AutoOffsetStrategyzio.kafka.consumer.Consumer.OffsetRetrieval.Auto→zio.kafka.consumer.Consumer.OffsetRetrievalzio.kafka.consumer.Consumer.OffsetRetrieval.External→zio.kafka.consumer.Consumer.AutoOffsetStrategyzio.kafka.consumer.Consumer.OffsetRetrieval.External→zio.kafka.consumer.Consumer.OffsetRetrievalzio.kafka.consumer.Consumer.OffsetRetrieval.Manual→zio.kafka.consumer.Consumer.AutoOffsetStrategyzio.kafka.consumer.Consumer.OffsetRetrieval.Manual→zio.kafka.consumer.Consumer.OffsetRetrieval
- Direction
- consumer.Consumer.OffsetRetrieval uses consumer.Consumer, so a change to consumer.Consumer can break consumer.Consumer.OffsetRetrieval, while a change to consumer.Consumer.OffsetRetrieval can't break consumer.Consumer.
- Position
- Below the diagonal: consumer.Consumer.OffsetRetrieval uses a module listed above it, which is the healthy direction.
12→6 consumer.Consumer.OffsetRetrieval uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 2 pairs of types, where a type in consumer.Consumer.OffsetRetrieval uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.Consumer.OffsetRetrieval.External→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.Consumer.OffsetRetrieval.Manual→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.Consumer.OffsetRetrieval uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.Consumer.OffsetRetrieval, while a change to consumer.Consumer.OffsetRetrieval can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.Consumer.OffsetRetrieval uses a module listed above it, which is the healthy direction.
13→4 consumer.metrics uses metrics.MetricInfo✕
- Connections
- 6 pairs of types, where a type in consumer.metrics uses a type in metrics.MetricInfo.
- The types involved
zio.kafka.consumer.metrics.ConsumerMetrics→zio.kafka.metrics.MetricInfo.Counterzio.kafka.consumer.metrics.ConsumerMetrics→zio.kafka.metrics.MetricInfo.Gaugezio.kafka.consumer.metrics.ConsumerMetrics→zio.kafka.metrics.MetricInfo.Histogramzio.kafka.consumer.metrics.ZioMetricsConsumerMetricsObserver→zio.kafka.metrics.MetricInfo.Counterzio.kafka.consumer.metrics.ZioMetricsConsumerMetricsObserver→zio.kafka.metrics.MetricInfo.Gaugezio.kafka.consumer.metrics.ZioMetricsConsumerMetricsObserver→zio.kafka.metrics.MetricInfo.Histogram
- Direction
- consumer.metrics uses metrics.MetricInfo, so a change to metrics.MetricInfo can break consumer.metrics, while a change to consumer.metrics can't break metrics.MetricInfo.
- Position
- Below the diagonal: consumer.metrics uses a module listed above it, which is the healthy direction.
13→6 consumer.metrics uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in consumer.metrics uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.metrics.ZioMetricsConsumerMetricsObserver→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.metrics uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.metrics, while a change to consumer.metrics can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.metrics uses a module listed above it, which is the healthy direction.
13→8 consumer.metrics uses consumer.metrics.ConsumerMetricsObserver✕
- Connections
- 2 pairs of types, where a type in consumer.metrics uses a type in consumer.metrics.ConsumerMetricsObserver.
- The types involved
zio.kafka.consumer.metrics.ConsumerMetricsObserver→zio.kafka.consumer.metrics.ConsumerMetricsObserver.ConsumerStatezio.kafka.consumer.metrics.ZioMetricsConsumerMetricsObserver→zio.kafka.consumer.metrics.ConsumerMetricsObserver.ConsumerState
- Direction
- consumer.metrics uses consumer.metrics.ConsumerMetricsObserver, so a change to consumer.metrics.ConsumerMetricsObserver can break consumer.metrics, while a change to consumer.metrics can't break consumer.metrics.ConsumerMetricsObserver.
- Position
- Below the diagonal: consumer.metrics uses a module listed above it, which is the healthy direction.
14→3 diagnostics.internal uses consumer.diagnostics✕
- Connections
- 1 pair of types, where a type in diagnostics.internal uses a type in consumer.diagnostics.
- The types involved
zio.kafka.diagnostics.internal.ConcurrentDiagnostics→zio.kafka.consumer.diagnostics.DiagnosticEvent
- Direction
- diagnostics.internal uses consumer.diagnostics, so a change to consumer.diagnostics can break diagnostics.internal, while a change to diagnostics.internal can't break consumer.diagnostics.
- Position
- Below the diagonal: diagnostics.internal uses a module listed above it, which is the healthy direction.
14→9 diagnostics.internal uses diagnostics✕
- Connections
- 1 pair of types, where a type in diagnostics.internal uses a type in diagnostics.
- The types involved
zio.kafka.diagnostics.internal.ConcurrentDiagnostics→zio.kafka.diagnostics.Diagnostics
- Direction
- diagnostics.internal uses diagnostics, so a change to diagnostics can break diagnostics.internal, while a change to diagnostics.internal can't break diagnostics.
- Position
- Below the diagonal: diagnostics.internal uses a module listed above it, which is the healthy direction.
15→4 metrics.internal.MetricInfoToZioMetric uses metrics.MetricInfo✕
- Connections
- 5 pairs of types, where a type in metrics.internal.MetricInfoToZioMetric uses a type in metrics.MetricInfo.
- The types involved
zio.kafka.metrics.internal.MetricInfoToZioMetric.CounterInfoToMetric→zio.kafka.metrics.MetricInfo.Counterzio.kafka.metrics.internal.MetricInfoToZioMetric.GaugeIntInfoToMetric→zio.kafka.metrics.MetricInfo.Gaugezio.kafka.metrics.internal.MetricInfoToZioMetric.HistogramDurationInfoToMetric→zio.kafka.metrics.MetricInfo.Histogramzio.kafka.metrics.internal.MetricInfoToZioMetric.HistogramIntInfoToMetric→zio.kafka.metrics.MetricInfo.Histogramzio.kafka.metrics.internal.MetricInfoToZioMetric.HistogramLongInfoToMetric→zio.kafka.metrics.MetricInfo.Histogram
- Direction
- metrics.internal.MetricInfoToZioMetric uses metrics.MetricInfo, so a change to metrics.MetricInfo can break metrics.internal.MetricInfoToZioMetric, while a change to metrics.internal.MetricInfoToZioMetric can't break metrics.MetricInfo.
- Position
- Below the diagonal: metrics.internal.MetricInfoToZioMetric uses a module listed above it, which is the healthy direction.
15→6 metrics.internal.MetricInfoToZioMetric uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 5 pairs of types, where a type in metrics.internal.MetricInfoToZioMetric uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.metrics.internal.MetricInfoToZioMetric.CounterInfoToMetric→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.metrics.internal.MetricInfoToZioMetric.GaugeIntInfoToMetric→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.metrics.internal.MetricInfoToZioMetric.HistogramDurationInfoToMetric→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.metrics.internal.MetricInfoToZioMetric.HistogramIntInfoToMetric→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.metrics.internal.MetricInfoToZioMetric.HistogramLongInfoToMetric→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- metrics.internal.MetricInfoToZioMetric uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break metrics.internal.MetricInfoToZioMetric, while a change to metrics.internal.MetricInfoToZioMetric can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: metrics.internal.MetricInfoToZioMetric uses a module listed above it, which is the healthy direction.
16→4 producer.metrics uses metrics.MetricInfo✕
- Connections
- 4 pairs of types, where a type in producer.metrics uses a type in metrics.MetricInfo.
- The types involved
zio.kafka.producer.metrics.ProducerMetrics→zio.kafka.metrics.MetricInfo.Counterzio.kafka.producer.metrics.ProducerMetrics→zio.kafka.metrics.MetricInfo.Histogramzio.kafka.producer.metrics.ZioMetricsProducerMetricsObserver→zio.kafka.metrics.MetricInfo.Counterzio.kafka.producer.metrics.ZioMetricsProducerMetricsObserver→zio.kafka.metrics.MetricInfo.Histogram
- Direction
- producer.metrics uses metrics.MetricInfo, so a change to metrics.MetricInfo can break producer.metrics, while a change to producer.metrics can't break metrics.MetricInfo.
- Position
- Below the diagonal: producer.metrics uses a module listed above it, which is the healthy direction.
16→6 producer.metrics uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in producer.metrics uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.producer.metrics.ZioMetricsProducerMetricsObserver→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- producer.metrics uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break producer.metrics, while a change to producer.metrics can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: producer.metrics uses a module listed above it, which is the healthy direction.
17→6 admin.AdminClient uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 6 pairs of types, where a type in admin.AdminClient uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.admin.AdminClient.ConsumerGroupDescription→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.admin.AdminClient.ListConsumerGroupsOptions→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.admin.AdminClient.ListGroupsOptions→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.admin.AdminClient.MemberDescription→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.admin.AdminClient.TopicDescription→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- admin.AdminClient uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break admin.AdminClient, while a change to admin.AdminClient can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: admin.AdminClient uses a module listed above it, which is the healthy direction.
17→7 admin.AdminClient uses admin.acl✕
- Connections
- 8 pairs of types, where a type in admin.AdminClient uses a type in admin.acl.
- The types involved
zio.kafka.admin.AdminClient.ConsumerGroupDescription→zio.kafka.admin.acl.AclOperationzio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.AclBindingzio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.AclBindingFilterzio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.AclOperationzio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.CreateAclOptionszio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.DeleteAclsOptionszio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.DescribeAclOptionszio.kafka.admin.AdminClient.TopicDescription→zio.kafka.admin.acl.AclOperation
- Direction
- admin.AdminClient uses admin.acl, so a change to admin.acl can break admin.AdminClient, while a change to admin.AdminClient can't break admin.acl.
- Position
- Below the diagonal: admin.AdminClient uses a module listed above it, which is the healthy direction.
17→11 admin.AdminClient uses admin.acl.AclOperation✕
- Connections
- 1 pair of types, where a type in admin.AdminClient uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.acl.AclOperation.Any
- Direction
- admin.AdminClient uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break admin.AdminClient, while a change to admin.AdminClient can't break admin.acl.AclOperation.
- Position
- Below the diagonal: admin.AdminClient uses a module listed above it, which is the healthy direction.
17→19 admin.AdminClient uses admin part of a loop✕
- Connections
- 1 pair of types, where a type in admin.AdminClient uses a type in admin.
- The types involved
zio.kafka.admin.AdminClient.LiveAdminClient→zio.kafka.admin.AdminClient
- Direction
- admin.AdminClient uses admin, so a change to admin can break admin.AdminClient, while a change to admin.AdminClient can't break admin.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
18→11 serde uses admin.acl.AclOperation✕
- Connections
- 1 pair of types, where a type in serde uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.serde.Serdes→zio.kafka.admin.acl.AclOperation.Any
- Direction
- serde uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break serde, while a change to serde can't break admin.acl.AclOperation.
- Position
- Below the diagonal: serde uses a module listed above it, which is the healthy direction.
19→5 admin uses security✕
- Connections
- 1 pair of types, where a type in admin uses a type in security.
- The types involved
zio.kafka.admin.AdminClientSettings→zio.kafka.security.KafkaCredentialStore
- Direction
- admin uses security, so a change to security can break admin, while a change to admin can't break security.
- Position
- Below the diagonal: admin uses a module listed above it, which is the healthy direction.
19→6 admin uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in admin uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- admin uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break admin, while a change to admin can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: admin uses a module listed above it, which is the healthy direction.
19→7 admin uses admin.acl✕
- Connections
- 6 pairs of types, where a type in admin uses a type in admin.acl.
- The types involved
zio.kafka.admin.AdminClient→zio.kafka.admin.acl.AclBindingzio.kafka.admin.AdminClient→zio.kafka.admin.acl.AclBindingFilterzio.kafka.admin.AdminClient→zio.kafka.admin.acl.AclOperationzio.kafka.admin.AdminClient→zio.kafka.admin.acl.CreateAclOptionszio.kafka.admin.AdminClient→zio.kafka.admin.acl.DeleteAclsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.acl.DescribeAclOptions
- Direction
- admin uses admin.acl, so a change to admin.acl can break admin, while a change to admin can't break admin.acl.
- Position
- Below the diagonal: admin uses a module listed above it, which is the healthy direction.
19→11 admin uses admin.acl.AclOperation✕
- Connections
- 1 pair of types, where a type in admin uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.admin.AdminClient→zio.kafka.admin.acl.AclOperation.Any
- Direction
- admin uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break admin, while a change to admin can't break admin.acl.AclOperation.
- Position
- Below the diagonal: admin uses a module listed above it, which is the healthy direction.
19→17 admin uses admin.AdminClient✕
- Connections
- 35 pairs of types, where a type in admin uses a type in admin.AdminClient. Showing 25 of them; the rest are in namespace-graph.json in this report's bundle.
- The types involved
zio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.AlterConfigOpzio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.AlterConfigsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.AlterConsumerGroupOffsetsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ConfigResourcezio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ConsumerGroupDescriptionzio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ConsumerGroupListingzio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.CreatePartitionsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.CreateTopicsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DeleteConsumerGroupOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DeleteRecordsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DeleteTopicsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DescribeClusterOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DescribeConfigsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DescribeConsumerGroupsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.DescribeTopicsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.GroupListingzio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.KafkaConfigzio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListConsumerGroupOffsetsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListConsumerGroupOffsetsSpeczio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListConsumerGroupsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListGroupsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListOffsetsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListOffsetsResultInfozio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.ListTopicsOptionszio.kafka.admin.AdminClient→zio.kafka.admin.AdminClient.LogDirDescription
- Direction
- admin uses admin.AdminClient, so a change to admin.AdminClient can break admin, while a change to admin can't break admin.AdminClient.
- Position
- Below the diagonal: admin uses a module listed above it, which is the healthy direction.
20→17 admin.AdminClient.ConfigResourceType uses admin.AdminClient✕
- Connections
- 6 pairs of types, where a type in admin.AdminClient.ConfigResourceType uses a type in admin.AdminClient.
- The types involved
zio.kafka.admin.AdminClient.ConfigResourceType.Broker→zio.kafka.admin.AdminClient.ConfigResourceTypezio.kafka.admin.AdminClient.ConfigResourceType.BrokerLogger→zio.kafka.admin.AdminClient.ConfigResourceTypezio.kafka.admin.AdminClient.ConfigResourceType.ClientMetrics→zio.kafka.admin.AdminClient.ConfigResourceTypezio.kafka.admin.AdminClient.ConfigResourceType.Group→zio.kafka.admin.AdminClient.ConfigResourceTypezio.kafka.admin.AdminClient.ConfigResourceType.Topic→zio.kafka.admin.AdminClient.ConfigResourceTypezio.kafka.admin.AdminClient.ConfigResourceType.Unknown→zio.kafka.admin.AdminClient.ConfigResourceType
- Direction
- admin.AdminClient.ConfigResourceType uses admin.AdminClient, so a change to admin.AdminClient can break admin.AdminClient.ConfigResourceType, while a change to admin.AdminClient.ConfigResourceType can't break admin.AdminClient.
- Position
- Below the diagonal: admin.AdminClient.ConfigResourceType uses a module listed above it, which is the healthy direction.
21→17 admin.AdminClient.GroupType uses admin.AdminClient✕
- Connections
- 5 pairs of types, where a type in admin.AdminClient.GroupType uses a type in admin.AdminClient.
- The types involved
zio.kafka.admin.AdminClient.GroupType.Classic→zio.kafka.admin.AdminClient.GroupTypezio.kafka.admin.AdminClient.GroupType.Consumer→zio.kafka.admin.AdminClient.GroupTypezio.kafka.admin.AdminClient.GroupType.Share→zio.kafka.admin.AdminClient.GroupTypezio.kafka.admin.AdminClient.GroupType.Streams→zio.kafka.admin.AdminClient.GroupTypezio.kafka.admin.AdminClient.GroupType.Unknown→zio.kafka.admin.AdminClient.GroupType
- Direction
- admin.AdminClient.GroupType uses admin.AdminClient, so a change to admin.AdminClient can break admin.AdminClient.GroupType, while a change to admin.AdminClient.GroupType can't break admin.AdminClient.
- Position
- Below the diagonal: admin.AdminClient.GroupType uses a module listed above it, which is the healthy direction.
22→3 consumer.diagnostics.DiagnosticEvent uses consumer.diagnostics✕
- Connections
- 7 pairs of types, where a type in consumer.diagnostics.DiagnosticEvent uses a type in consumer.diagnostics.
- The types involved
zio.kafka.consumer.diagnostics.DiagnosticEvent.Commit→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.consumer.diagnostics.DiagnosticEvent.ConsumerFinalized→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.consumer.diagnostics.DiagnosticEvent.Poll→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.consumer.diagnostics.DiagnosticEvent.Rebalance→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.consumer.diagnostics.DiagnosticEvent.Request→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.consumer.diagnostics.DiagnosticEvent.RunloopFinalized→zio.kafka.consumer.diagnostics.DiagnosticEventzio.kafka.consumer.diagnostics.DiagnosticEvent.SubscriptionFinalized→zio.kafka.consumer.diagnostics.DiagnosticEvent
- Direction
- consumer.diagnostics.DiagnosticEvent uses consumer.diagnostics, so a change to consumer.diagnostics can break consumer.diagnostics.DiagnosticEvent, while a change to consumer.diagnostics.DiagnosticEvent can't break consumer.diagnostics.
- Position
- Below the diagonal: consumer.diagnostics.DiagnosticEvent uses a module listed above it, which is the healthy direction.
22→6 consumer.diagnostics.DiagnosticEvent uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 2 pairs of types, where a type in consumer.diagnostics.DiagnosticEvent uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.diagnostics.DiagnosticEvent.Poll→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.diagnostics.DiagnosticEvent.Rebalance→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.diagnostics.DiagnosticEvent uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.diagnostics.DiagnosticEvent, while a change to consumer.diagnostics.DiagnosticEvent can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.diagnostics.DiagnosticEvent uses a module listed above it, which is the healthy direction.
22→17 consumer.diagnostics.DiagnosticEvent uses admin.AdminClient✕
- Connections
- 3 pairs of types, where a type in consumer.diagnostics.DiagnosticEvent uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.diagnostics.DiagnosticEvent.Poll→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.diagnostics.DiagnosticEvent.Rebalance→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.diagnostics.DiagnosticEvent.Request→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.diagnostics.DiagnosticEvent uses admin.AdminClient, so a change to admin.AdminClient can break consumer.diagnostics.DiagnosticEvent, while a change to consumer.diagnostics.DiagnosticEvent can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.diagnostics.DiagnosticEvent uses a module listed above it, which is the healthy direction.
23→6 consumer.internal.RebalanceCoordinator uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in consumer.internal.RebalanceCoordinator uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.internal.RebalanceCoordinator.RebalanceCallback→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.internal.RebalanceCoordinator uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.internal.RebalanceCoordinator, while a change to consumer.internal.RebalanceCoordinator can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.internal.RebalanceCoordinator uses a module listed above it, which is the healthy direction.
23→17 consumer.internal.RebalanceCoordinator uses admin.AdminClient✕
- Connections
- 2 pairs of types, where a type in consumer.internal.RebalanceCoordinator uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.internal.RebalanceCoordinator.RebalanceCallback→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.internal.RebalanceCoordinator.StreamCompletionStatus→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.internal.RebalanceCoordinator uses admin.AdminClient, so a change to admin.AdminClient can break consumer.internal.RebalanceCoordinator, while a change to consumer.internal.RebalanceCoordinator can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.internal.RebalanceCoordinator uses a module listed above it, which is the healthy direction.
23→28 consumer.internal.RebalanceCoordinator uses consumer.internal part of a loop✕
- Connections
- 1 pair of types, where a type in consumer.internal.RebalanceCoordinator uses a type in consumer.internal.
- The types involved
zio.kafka.consumer.internal.RebalanceCoordinator.RebalanceCallback→zio.kafka.consumer.internal.PartitionStreamControl
- Direction
- consumer.internal.RebalanceCoordinator uses consumer.internal, so a change to consumer.internal can break consumer.internal.RebalanceCoordinator, while a change to consumer.internal.RebalanceCoordinator can't break consumer.internal.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
24→17 consumer.internal.RunloopCommand uses admin.AdminClient✕
- Connections
- 1 pair of types, where a type in consumer.internal.RunloopCommand uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.internal.RunloopCommand.Request→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.internal.RunloopCommand uses admin.AdminClient, so a change to admin.AdminClient can break consumer.internal.RunloopCommand, while a change to consumer.internal.RunloopCommand can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.internal.RunloopCommand uses a module listed above it, which is the healthy direction.
24→28 consumer.internal.RunloopCommand uses consumer.internal part of a loop✕
- Connections
- 2 pairs of types, where a type in consumer.internal.RunloopCommand uses a type in consumer.internal.
- The types involved
zio.kafka.consumer.internal.RunloopCommand.Control→zio.kafka.consumer.internal.RunloopCommandzio.kafka.consumer.internal.RunloopCommand.StreamCommand→zio.kafka.consumer.internal.RunloopCommand
- Direction
- consumer.internal.RunloopCommand uses consumer.internal, so a change to consumer.internal can break consumer.internal.RunloopCommand, while a change to consumer.internal.RunloopCommand can't break consumer.internal.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
24→30 consumer.internal.RunloopCommand uses consumer part of a loop✕
- Connections
- 4 pairs of types, where a type in consumer.internal.RunloopCommand uses a type in consumer.
- The types involved
zio.kafka.consumer.internal.RunloopCommand.AddSubscription→zio.kafka.consumer.InvalidSubscriptionUnionzio.kafka.consumer.internal.RunloopCommand.AddSubscription→zio.kafka.consumer.Subscriptionzio.kafka.consumer.internal.RunloopCommand.EndStreamsBySubscription→zio.kafka.consumer.Subscriptionzio.kafka.consumer.internal.RunloopCommand.RemoveSubscription→zio.kafka.consumer.Subscription
- Direction
- consumer.internal.RunloopCommand uses consumer, so a change to consumer can break consumer.internal.RunloopCommand, while a change to consumer.internal.RunloopCommand can't break consumer.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
25→17 consumer.diagnostics.DiagnosticEvent.Commit uses admin.AdminClient✕
- Connections
- 6 pairs of types, where a type in consumer.diagnostics.DiagnosticEvent.Commit uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Failure→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Failure→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Started→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Started→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Success→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Success→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.diagnostics.DiagnosticEvent.Commit uses admin.AdminClient, so a change to admin.AdminClient can break consumer.diagnostics.DiagnosticEvent.Commit, while a change to consumer.diagnostics.DiagnosticEvent.Commit can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.diagnostics.DiagnosticEvent.Commit uses a module listed above it, which is the healthy direction.
25→22 consumer.diagnostics.DiagnosticEvent.Commit uses consumer.diagnostics.DiagnosticEvent✕
- Connections
- 3 pairs of types, where a type in consumer.diagnostics.DiagnosticEvent.Commit uses a type in consumer.diagnostics.DiagnosticEvent.
- The types involved
zio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Failure→zio.kafka.consumer.diagnostics.DiagnosticEvent.Commitzio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Started→zio.kafka.consumer.diagnostics.DiagnosticEvent.Commitzio.kafka.consumer.diagnostics.DiagnosticEvent.Commit.Success→zio.kafka.consumer.diagnostics.DiagnosticEvent.Commit
- Direction
- consumer.diagnostics.DiagnosticEvent.Commit uses consumer.diagnostics.DiagnosticEvent, so a change to consumer.diagnostics.DiagnosticEvent can break consumer.diagnostics.DiagnosticEvent.Commit, while a change to consumer.diagnostics.DiagnosticEvent.Commit can't break consumer.diagnostics.DiagnosticEvent.
- Position
- Below the diagonal: consumer.diagnostics.DiagnosticEvent.Commit uses a module listed above it, which is the healthy direction.
26→6 consumer.internal.Committer uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in consumer.internal.Committer uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.internal.Committer.CommitOffsets→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.internal.Committer uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.internal.Committer, while a change to consumer.internal.Committer can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.internal.Committer uses a module listed above it, which is the healthy direction.
26→17 consumer.internal.Committer uses admin.AdminClient✕
- Connections
- 1 pair of types, where a type in consumer.internal.Committer uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.internal.Committer.CommitOffsets→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.internal.Committer uses admin.AdminClient, so a change to admin.AdminClient can break consumer.internal.Committer, while a change to consumer.internal.Committer can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.internal.Committer uses a module listed above it, which is the healthy direction.
26→22 consumer.internal.Committer uses consumer.diagnostics.DiagnosticEvent✕
- Connections
- 1 pair of types, where a type in consumer.internal.Committer uses a type in consumer.diagnostics.DiagnosticEvent.
- The types involved
zio.kafka.consumer.internal.Committer.CommitOffsets→zio.kafka.consumer.diagnostics.DiagnosticEvent.Commit
- Direction
- consumer.internal.Committer uses consumer.diagnostics.DiagnosticEvent, so a change to consumer.diagnostics.DiagnosticEvent can break consumer.internal.Committer, while a change to consumer.internal.Committer can't break consumer.diagnostics.DiagnosticEvent.
- Position
- Below the diagonal: consumer.internal.Committer uses a module listed above it, which is the healthy direction.
27→6 consumer.internal.Runloop uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in consumer.internal.Runloop uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.internal.Runloop.PollResult→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.internal.Runloop uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.internal.Runloop, while a change to consumer.internal.Runloop can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.internal.Runloop uses a module listed above it, which is the healthy direction.
27→17 consumer.internal.Runloop uses admin.AdminClient✕
- Connections
- 1 pair of types, where a type in consumer.internal.Runloop uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.internal.Runloop.PollResult→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.internal.Runloop uses admin.AdminClient, so a change to admin.AdminClient can break consumer.internal.Runloop, while a change to consumer.internal.Runloop can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.internal.Runloop uses a module listed above it, which is the healthy direction.
27→22 consumer.internal.Runloop uses consumer.diagnostics.DiagnosticEvent✕
- Connections
- 4 pairs of types, where a type in consumer.internal.Runloop uses a type in consumer.diagnostics.DiagnosticEvent.
- The types involved
zio.kafka.consumer.internal.Runloop.FulfillResult→zio.kafka.consumer.diagnostics.DiagnosticEvent.Requestzio.kafka.consumer.internal.Runloop.PollResult→zio.kafka.consumer.diagnostics.DiagnosticEvent.Requestzio.kafka.consumer.internal.Runloop.RevokeResult→zio.kafka.consumer.diagnostics.DiagnosticEvent.Requestzio.kafka.consumer.internal.Runloop.State→zio.kafka.consumer.diagnostics.DiagnosticEvent.Request
- Direction
- consumer.internal.Runloop uses consumer.diagnostics.DiagnosticEvent, so a change to consumer.diagnostics.DiagnosticEvent can break consumer.internal.Runloop, while a change to consumer.internal.Runloop can't break consumer.diagnostics.DiagnosticEvent.
- Position
- Below the diagonal: consumer.internal.Runloop uses a module listed above it, which is the healthy direction.
27→28 consumer.internal.Runloop uses consumer.internal part of a loop✕
- Connections
- 4 pairs of types, where a type in consumer.internal.Runloop uses a type in consumer.internal.
- The types involved
zio.kafka.consumer.internal.Runloop.PollResult→zio.kafka.consumer.internal.PartitionStreamControlzio.kafka.consumer.internal.Runloop.RevokeResult→zio.kafka.consumer.internal.PartitionStreamControlzio.kafka.consumer.internal.Runloop.State→zio.kafka.consumer.internal.PartitionStreamControlzio.kafka.consumer.internal.Runloop.State→zio.kafka.consumer.internal.SubscriptionState
- Direction
- consumer.internal.Runloop uses consumer.internal, so a change to consumer.internal can break consumer.internal.Runloop, while a change to consumer.internal.Runloop can't break consumer.internal.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
28→6 consumer.internal uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 3 pairs of types, where a type in consumer.internal uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.internal.Committer→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.internal.LiveCommitter→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.internal.Runloop→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.internal uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.internal, while a change to consumer.internal can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→11 consumer.internal uses admin.acl.AclOperation✕
- Connections
- 4 pairs of types, where a type in consumer.internal uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.consumer.internal.PartitionStreamControl→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.internal.RebalanceCoordinator→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.internal.Runloop→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.internal.RunloopAccess→zio.kafka.admin.acl.AclOperation.Any
- Direction
- consumer.internal uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break consumer.internal, while a change to consumer.internal can't break admin.acl.AclOperation.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→17 consumer.internal uses admin.AdminClient✕
- Connections
- 7 pairs of types, where a type in consumer.internal uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.internal.Committer→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.internal.Committer→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.internal.LiveCommitter→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.internal.LiveCommitter→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.internal.PartitionStream→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.internal.PartitionStreamControl→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.internal.Runloop→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.internal uses admin.AdminClient, so a change to admin.AdminClient can break consumer.internal, while a change to consumer.internal can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→22 consumer.internal uses consumer.diagnostics.DiagnosticEvent✕
- Connections
- 2 pairs of types, where a type in consumer.internal uses a type in consumer.diagnostics.DiagnosticEvent.
- The types involved
zio.kafka.consumer.internal.LiveCommitter→zio.kafka.consumer.diagnostics.DiagnosticEvent.Commitzio.kafka.consumer.internal.Runloop→zio.kafka.consumer.diagnostics.DiagnosticEvent.Request
- Direction
- consumer.internal uses consumer.diagnostics.DiagnosticEvent, so a change to consumer.diagnostics.DiagnosticEvent can break consumer.internal, while a change to consumer.internal can't break consumer.diagnostics.DiagnosticEvent.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→23 consumer.internal uses consumer.internal.RebalanceCoordinator✕
- Connections
- 1 pair of types, where a type in consumer.internal uses a type in consumer.internal.RebalanceCoordinator.
- The types involved
zio.kafka.consumer.internal.RebalanceCoordinator→zio.kafka.consumer.internal.RebalanceCoordinator.RebalanceEvent
- Direction
- consumer.internal uses consumer.internal.RebalanceCoordinator, so a change to consumer.internal.RebalanceCoordinator can break consumer.internal, while a change to consumer.internal can't break consumer.internal.RebalanceCoordinator.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→24 consumer.internal uses consumer.internal.RunloopCommand✕
- Connections
- 1 pair of types, where a type in consumer.internal uses a type in consumer.internal.RunloopCommand.
- The types involved
zio.kafka.consumer.internal.Runloop→zio.kafka.consumer.internal.RunloopCommand.StreamCommand
- Direction
- consumer.internal uses consumer.internal.RunloopCommand, so a change to consumer.internal.RunloopCommand can break consumer.internal, while a change to consumer.internal can't break consumer.internal.RunloopCommand.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→26 consumer.internal uses consumer.internal.Committer✕
- Connections
- 2 pairs of types, where a type in consumer.internal uses a type in consumer.internal.Committer.
- The types involved
zio.kafka.consumer.internal.Committer→zio.kafka.consumer.internal.Committer.CommitOffsetszio.kafka.consumer.internal.LiveCommitter→zio.kafka.consumer.internal.Committer.CommitOffsets
- Direction
- consumer.internal uses consumer.internal.Committer, so a change to consumer.internal.Committer can break consumer.internal, while a change to consumer.internal can't break consumer.internal.Committer.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→27 consumer.internal uses consumer.internal.Runloop✕
- Connections
- 3 pairs of types, where a type in consumer.internal uses a type in consumer.internal.Runloop.
- The types involved
zio.kafka.consumer.internal.Runloop→zio.kafka.consumer.internal.Runloop.FulfillResultzio.kafka.consumer.internal.Runloop→zio.kafka.consumer.internal.Runloop.RevokeResultzio.kafka.consumer.internal.Runloop→zio.kafka.consumer.internal.Runloop.State
- Direction
- consumer.internal uses consumer.internal.Runloop, so a change to consumer.internal.Runloop can break consumer.internal, while a change to consumer.internal can't break consumer.internal.Runloop.
- Position
- Below the diagonal: consumer.internal uses a module listed above it, which is the healthy direction.
28→30 consumer.internal uses consumer part of a loop✕
- Connections
- 7 pairs of types, where a type in consumer.internal uses a type in consumer.
- The types involved
zio.kafka.consumer.internal.PartitionStreamControl→zio.kafka.consumer.Offsetzio.kafka.consumer.internal.RebalanceCoordinator→zio.kafka.consumer.RebalanceListenerzio.kafka.consumer.internal.Runloop→zio.kafka.consumer.OffsetBatchzio.kafka.consumer.internal.Runloop→zio.kafka.consumer.Subscriptionzio.kafka.consumer.internal.RunloopAccess→zio.kafka.consumer.OffsetBatchzio.kafka.consumer.internal.RunloopAccess→zio.kafka.consumer.StreamControlzio.kafka.consumer.internal.RunloopAccess→zio.kafka.consumer.Subscription
- Direction
- consumer.internal uses consumer, so a change to consumer can break consumer.internal, while a change to consumer.internal can't break consumer.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
29→6 consumer.fetch uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 3 pairs of types, where a type in consumer.fetch uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.fetch.FetchStrategy→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.fetch.ManyPartitionsQueueSizeBasedFetchStrategy→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.fetch uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.fetch, while a change to consumer.fetch can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.fetch uses a module listed above it, which is the healthy direction.
29→11 consumer.fetch uses admin.acl.AclOperation✕
- Connections
- 3 pairs of types, where a type in consumer.fetch uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.consumer.fetch.FetchStrategy→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.fetch.ManyPartitionsQueueSizeBasedFetchStrategy→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy→zio.kafka.admin.acl.AclOperation.Any
- Direction
- consumer.fetch uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break consumer.fetch, while a change to consumer.fetch can't break admin.acl.AclOperation.
- Position
- Below the diagonal: consumer.fetch uses a module listed above it, which is the healthy direction.
29→17 consumer.fetch uses admin.AdminClient✕
- Connections
- 3 pairs of types, where a type in consumer.fetch uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.fetch.FetchStrategy→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.fetch.ManyPartitionsQueueSizeBasedFetchStrategy→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.fetch uses admin.AdminClient, so a change to admin.AdminClient can break consumer.fetch, while a change to consumer.fetch can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.fetch uses a module listed above it, which is the healthy direction.
29→28 consumer.fetch uses consumer.internal✕
- Connections
- 3 pairs of types, where a type in consumer.fetch uses a type in consumer.internal.
- The types involved
zio.kafka.consumer.fetch.FetchStrategy→zio.kafka.consumer.internal.PartitionStreamzio.kafka.consumer.fetch.ManyPartitionsQueueSizeBasedFetchStrategy→zio.kafka.consumer.internal.PartitionStreamzio.kafka.consumer.fetch.QueueSizeBasedFetchStrategy→zio.kafka.consumer.internal.PartitionStream
- Direction
- consumer.fetch uses consumer.internal, so a change to consumer.internal can break consumer.fetch, while a change to consumer.fetch can't break consumer.internal.
- Position
- Below the diagonal: consumer.fetch uses a module listed above it, which is the healthy direction.
30→2 consumer uses consumer.Consumer✕
- Connections
- 1 pair of types, where a type in consumer uses a type in consumer.Consumer.
- The types involved
zio.kafka.consumer.ConsumerSettings→zio.kafka.consumer.Consumer.OffsetRetrieval
- Direction
- consumer uses consumer.Consumer, so a change to consumer.Consumer can break consumer, while a change to consumer can't break consumer.Consumer.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→5 consumer uses security✕
- Connections
- 1 pair of types, where a type in consumer uses a type in security.
- The types involved
zio.kafka.consumer.ConsumerSettings→zio.kafka.security.KafkaCredentialStore
- Direction
- consumer uses security, so a change to security can break consumer, while a change to consumer can't break security.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→6 consumer uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 4 pairs of types, where a type in consumer uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.Consumer→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.ConsumerLive→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.ConsumerSettings→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.RebalanceListener→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer, while a change to consumer can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→11 consumer uses admin.acl.AclOperation✕
- Connections
- 6 pairs of types, where a type in consumer uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.consumer.Consumer→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.ConsumerLive→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.ConsumerSettings→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.Offset→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.OffsetBatch→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.consumer.internal→zio.kafka.admin.acl.AclOperation.Any
- Direction
- consumer uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break consumer, while a change to consumer can't break admin.acl.AclOperation.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→13 consumer uses consumer.metrics✕
- Connections
- 1 pair of types, where a type in consumer uses a type in consumer.metrics.
- The types involved
zio.kafka.consumer.ConsumerSettings→zio.kafka.consumer.metrics.ConsumerMetricsObserver
- Direction
- consumer uses consumer.metrics, so a change to consumer.metrics can break consumer, while a change to consumer can't break consumer.metrics.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→17 consumer uses admin.AdminClient✕
- Connections
- 16 pairs of types, where a type in consumer uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.Consumer→zio.kafka.admin.AdminClient.Metriczio.kafka.consumer.Consumer→zio.kafka.admin.AdminClient.MetricNamezio.kafka.consumer.Consumer→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.Consumer→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.ConsumerLive→zio.kafka.admin.AdminClient.Metriczio.kafka.consumer.ConsumerLive→zio.kafka.admin.AdminClient.MetricNamezio.kafka.consumer.ConsumerLive→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.ConsumerLive→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.EmptyOffsetBatch→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.EmptyOffsetBatch→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.Offset→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.Offset→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.OffsetBatch→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.OffsetBatch→zio.kafka.admin.AdminClient.TopicPartitionzio.kafka.consumer.OffsetBatchImpl→zio.kafka.admin.AdminClient.OffsetAndMetadatazio.kafka.consumer.OffsetBatchImpl→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer uses admin.AdminClient, so a change to admin.AdminClient can break consumer, while a change to consumer can't break admin.AdminClient.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→18 consumer uses serde✕
- Connections
- 3 pairs of types, where a type in consumer uses a type in serde.
- The types involved
zio.kafka.consumer.CommittableRecord→zio.kafka.serde.Deserializerzio.kafka.consumer.Consumer→zio.kafka.serde.Deserializerzio.kafka.consumer.ConsumerLive→zio.kafka.serde.Deserializer
- Direction
- consumer uses serde, so a change to serde can break consumer, while a change to consumer can't break serde.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→21 consumer uses admin.AdminClient.GroupType✕
- Connections
- 1 pair of types, where a type in consumer uses a type in admin.AdminClient.GroupType.
- The types involved
zio.kafka.consumer.ConsumerLive→zio.kafka.admin.AdminClient.GroupType.Consumer
- Direction
- consumer uses admin.AdminClient.GroupType, so a change to admin.AdminClient.GroupType can break consumer, while a change to consumer can't break admin.AdminClient.GroupType.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
30→29 consumer uses consumer.fetch✕
- Connections
- 1 pair of types, where a type in consumer uses a type in consumer.fetch.
- The types involved
zio.kafka.consumer.ConsumerSettings→zio.kafka.consumer.fetch.FetchStrategy
- Direction
- consumer uses consumer.fetch, so a change to consumer.fetch can break consumer, while a change to consumer can't break consumer.fetch.
- Position
- Below the diagonal: consumer uses a module listed above it, which is the healthy direction.
31→6 consumer.Subscription uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 2 pairs of types, where a type in consumer.Subscription uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.Subscription.Manual→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.consumer.Subscription.Topics→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.Subscription uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.Subscription, while a change to consumer.Subscription can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.Subscription uses a module listed above it, which is the healthy direction.
31→17 consumer.Subscription uses admin.AdminClient✕
- Connections
- 1 pair of types, where a type in consumer.Subscription uses a type in admin.AdminClient.
- The types involved
zio.kafka.consumer.Subscription.Manual→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- consumer.Subscription uses admin.AdminClient, so a change to admin.AdminClient can break consumer.Subscription, while a change to consumer.Subscription can't break admin.AdminClient.
- Position
- Below the diagonal: consumer.Subscription uses a module listed above it, which is the healthy direction.
31→30 consumer.Subscription uses consumer✕
- Connections
- 3 pairs of types, where a type in consumer.Subscription uses a type in consumer.
- The types involved
zio.kafka.consumer.Subscription.Manual→zio.kafka.consumer.Subscriptionzio.kafka.consumer.Subscription.Pattern→zio.kafka.consumer.Subscriptionzio.kafka.consumer.Subscription.Topics→zio.kafka.consumer.Subscription
- Direction
- consumer.Subscription uses consumer, so a change to consumer can break consumer.Subscription, while a change to consumer.Subscription can't break consumer.
- Position
- Below the diagonal: consumer.Subscription uses a module listed above it, which is the healthy direction.
32→6 consumer.internal.SubscriptionState uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in consumer.internal.SubscriptionState uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.consumer.internal.SubscriptionState.Subscribed→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- consumer.internal.SubscriptionState uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break consumer.internal.SubscriptionState, while a change to consumer.internal.SubscriptionState can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: consumer.internal.SubscriptionState uses a module listed above it, which is the healthy direction.
32→28 consumer.internal.SubscriptionState uses consumer.internal✕
- Connections
- 2 pairs of types, where a type in consumer.internal.SubscriptionState uses a type in consumer.internal.
- The types involved
zio.kafka.consumer.internal.SubscriptionState.NotSubscribed→zio.kafka.consumer.internal.SubscriptionStatezio.kafka.consumer.internal.SubscriptionState.Subscribed→zio.kafka.consumer.internal.SubscriptionState
- Direction
- consumer.internal.SubscriptionState uses consumer.internal, so a change to consumer.internal can break consumer.internal.SubscriptionState, while a change to consumer.internal.SubscriptionState can't break consumer.internal.
- Position
- Below the diagonal: consumer.internal.SubscriptionState uses a module listed above it, which is the healthy direction.
32→30 consumer.internal.SubscriptionState uses consumer✕
- Connections
- 1 pair of types, where a type in consumer.internal.SubscriptionState uses a type in consumer.
- The types involved
zio.kafka.consumer.internal.SubscriptionState.Subscribed→zio.kafka.consumer.Subscription
- Direction
- consumer.internal.SubscriptionState uses consumer, so a change to consumer can break consumer.internal.SubscriptionState, while a change to consumer.internal.SubscriptionState can't break consumer.
- Position
- Below the diagonal: consumer.internal.SubscriptionState uses a module listed above it, which is the healthy direction.
33→11 producer.TransactionalProducer uses admin.acl.AclOperation✕
- Connections
- 1 pair of types, where a type in producer.TransactionalProducer uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.producer.TransactionalProducer.LiveTransactionalProducer→zio.kafka.admin.acl.AclOperation.Any
- Direction
- producer.TransactionalProducer uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break producer.TransactionalProducer, while a change to producer.TransactionalProducer can't break admin.acl.AclOperation.
- Position
- Below the diagonal: producer.TransactionalProducer uses a module listed above it, which is the healthy direction.
33→30 producer.TransactionalProducer uses consumer✕
- Connections
- 2 pairs of types, where a type in producer.TransactionalProducer uses a type in consumer.
- The types involved
zio.kafka.producer.TransactionalProducer.LiveTransactionalProducer→zio.kafka.consumer.OffsetBatchzio.kafka.producer.TransactionalProducer.TransactionLeaked→zio.kafka.consumer.OffsetBatch
- Direction
- producer.TransactionalProducer uses consumer, so a change to consumer can break producer.TransactionalProducer, while a change to producer.TransactionalProducer can't break consumer.
- Position
- Below the diagonal: producer.TransactionalProducer uses a module listed above it, which is the healthy direction.
33→34 producer.TransactionalProducer uses producer part of a loop✕
- Connections
- 3 pairs of types, where a type in producer.TransactionalProducer uses a type in producer.
- The types involved
zio.kafka.producer.TransactionalProducer.LiveTransactionalProducer→zio.kafka.producer.Transactionzio.kafka.producer.TransactionalProducer.LiveTransactionalProducer→zio.kafka.producer.TransactionImplzio.kafka.producer.TransactionalProducer.LiveTransactionalProducer→zio.kafka.producer.TransactionalProducer
- Direction
- producer.TransactionalProducer uses producer, so a change to producer can break producer.TransactionalProducer, while a change to producer.TransactionalProducer can't break producer.
- Position
- Above the diagonal, so it is part of a loop. Neither module can be changed, tested or released on its own until one of these dependencies is removed.
34→5 producer uses security✕
- Connections
- 1 pair of types, where a type in producer uses a type in security.
- The types involved
zio.kafka.producer.ProducerSettings→zio.kafka.security.KafkaCredentialStore
- Direction
- producer uses security, so a change to security can break producer, while a change to producer can't break security.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→6 producer uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 2 pairs of types, where a type in producer uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.producer.ProducerLive→zio.kafka.admin.AdminClient.AlterConfigOpType.Setzio.kafka.producer.ProducerSettings→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- producer uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break producer, while a change to producer can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→11 producer uses admin.acl.AclOperation✕
- Connections
- 3 pairs of types, where a type in producer uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.producer.DiagnosticsEmitter→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.producer.EmptyDiagnosticsEmitter→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.producer.ProducerSettings→zio.kafka.admin.acl.AclOperation.Any
- Direction
- producer uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break producer, while a change to producer can't break admin.acl.AclOperation.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→16 producer uses producer.metrics✕
- Connections
- 1 pair of types, where a type in producer uses a type in producer.metrics.
- The types involved
zio.kafka.producer.ProducerSettings→zio.kafka.producer.metrics.ProducerMetricsObserver
- Direction
- producer uses producer.metrics, so a change to producer.metrics can break producer, while a change to producer can't break producer.metrics.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→17 producer uses admin.AdminClient✕
- Connections
- 2 pairs of types, where a type in producer uses a type in admin.AdminClient.
- The types involved
zio.kafka.producer.Producer→zio.kafka.admin.AdminClient.Metriczio.kafka.producer.Producer→zio.kafka.admin.AdminClient.MetricName
- Direction
- producer uses admin.AdminClient, so a change to admin.AdminClient can break producer, while a change to producer can't break admin.AdminClient.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→18 producer uses serde✕
- Connections
- 3 pairs of types, where a type in producer uses a type in serde.
- The types involved
zio.kafka.producer.Producer→zio.kafka.serde.Serializerzio.kafka.producer.Transaction→zio.kafka.serde.Serializerzio.kafka.producer.TransactionImpl→zio.kafka.serde.Serializer
- Direction
- producer uses serde, so a change to serde can break producer, while a change to producer can't break serde.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→30 producer uses consumer✕
- Connections
- 4 pairs of types, where a type in producer uses a type in consumer.
- The types involved
zio.kafka.producer.Transaction→zio.kafka.consumer.Offsetzio.kafka.producer.Transaction→zio.kafka.consumer.OffsetBatchzio.kafka.producer.TransactionImpl→zio.kafka.consumer.Offsetzio.kafka.producer.TransactionImpl→zio.kafka.consumer.OffsetBatch
- Direction
- producer uses consumer, so a change to consumer can break producer, while a change to producer can't break consumer.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
34→33 producer uses producer.TransactionalProducer✕
- Connections
- 1 pair of types, where a type in producer uses a type in producer.TransactionalProducer.
- The types involved
zio.kafka.producer.TransactionImpl→zio.kafka.producer.TransactionalProducer.TransactionLeaked
- Direction
- producer uses producer.TransactionalProducer, so a change to producer.TransactionalProducer can break producer, while a change to producer can't break producer.TransactionalProducer.
- Position
- Below the diagonal: producer uses a module listed above it, which is the healthy direction.
35→11 example uses admin.acl.AclOperation✕
- Connections
- 3 pairs of types, where a type in example uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.example.Main→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.example.ReadmeExample→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.example.Transactional→zio.kafka.admin.acl.AclOperation.Any
- Direction
- example uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break example, while a change to example can't break admin.acl.AclOperation.
- Position
- Below the diagonal: example uses a module listed above it, which is the healthy direction.
35→21 example uses admin.AdminClient.GroupType✕
- Connections
- 1 pair of types, where a type in example uses a type in admin.AdminClient.GroupType.
- The types involved
zio.kafka.example.Main→zio.kafka.admin.AdminClient.GroupType.Consumer
- Direction
- example uses admin.AdminClient.GroupType, so a change to admin.AdminClient.GroupType can break example, while a change to example can't break admin.AdminClient.GroupType.
- Position
- Below the diagonal: example uses a module listed above it, which is the healthy direction.
35→30 example uses consumer✕
- Connections
- 2 pairs of types, where a type in example uses a type in consumer.
- The types involved
zio.kafka.example.Main→zio.kafka.consumer.ConsumerSettingszio.kafka.example.Transactional→zio.kafka.consumer.ConsumerSettings
- Direction
- example uses consumer, so a change to consumer can break example, while a change to example can't break consumer.
- Position
- Below the diagonal: example uses a module listed above it, which is the healthy direction.
35→34 example uses producer✕
- Connections
- 1 pair of types, where a type in example uses a type in producer.
- The types involved
zio.kafka.example.Transactional→zio.kafka.producer.TransactionalProducerSettings
- Direction
- example uses producer, so a change to producer can break example, while a change to example can't break producer.
- Position
- Below the diagonal: example uses a module listed above it, which is the healthy direction.
36→6 producer.ProducerEvent uses admin.AdminClient.AlterConfigOpType✕
- Connections
- 1 pair of types, where a type in producer.ProducerEvent uses a type in admin.AdminClient.AlterConfigOpType.
- The types involved
zio.kafka.producer.ProducerEvent.RecordsSent→zio.kafka.admin.AdminClient.AlterConfigOpType.Set
- Direction
- producer.ProducerEvent uses admin.AdminClient.AlterConfigOpType, so a change to admin.AdminClient.AlterConfigOpType can break producer.ProducerEvent, while a change to producer.ProducerEvent can't break admin.AdminClient.AlterConfigOpType.
- Position
- Below the diagonal: producer.ProducerEvent uses a module listed above it, which is the healthy direction.
36→34 producer.ProducerEvent uses producer✕
- Connections
- 3 pairs of types, where a type in producer.ProducerEvent uses a type in producer.
- The types involved
zio.kafka.producer.ProducerEvent.ProducerFinalized→zio.kafka.producer.ProducerEventzio.kafka.producer.ProducerEvent.RecordsOffered→zio.kafka.producer.ProducerEventzio.kafka.producer.ProducerEvent.RecordsSent→zio.kafka.producer.ProducerEvent
- Direction
- producer.ProducerEvent uses producer, so a change to producer can break producer.ProducerEvent, while a change to producer.ProducerEvent can't break producer.
- Position
- Below the diagonal: producer.ProducerEvent uses a module listed above it, which is the healthy direction.
37→11 producer.ProducerLive uses admin.acl.AclOperation✕
- Connections
- 1 pair of types, where a type in producer.ProducerLive uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.producer.ProducerLive.BatchDiagnosticsEmitter→zio.kafka.admin.acl.AclOperation.Any
- Direction
- producer.ProducerLive uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break producer.ProducerLive, while a change to producer.ProducerLive can't break admin.acl.AclOperation.
- Position
- Below the diagonal: producer.ProducerLive uses a module listed above it, which is the healthy direction.
37→34 producer.ProducerLive uses producer✕
- Connections
- 3 pairs of types, where a type in producer.ProducerLive uses a type in producer.
- The types involved
zio.kafka.producer.ProducerLive.BatchDiagnosticsEmitter→zio.kafka.producer.DiagnosticsEmitterzio.kafka.producer.ProducerLive.BatchDiagnosticsEmitterMaker→zio.kafka.producer.DiagnosticsEmitterzio.kafka.producer.ProducerLive.BatchDiagnosticsEmitterMaker→zio.kafka.producer.DiagnosticsEmitterMaker
- Direction
- producer.ProducerLive uses producer, so a change to producer can break producer.ProducerLive, while a change to producer.ProducerLive can't break producer.
- Position
- Below the diagonal: producer.ProducerLive uses a module listed above it, which is the healthy direction.
38→2 testkit uses consumer.Consumer✕
- Connections
- 1 pair of types, where a type in testkit uses a type in consumer.Consumer.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.consumer.Consumer.OffsetRetrieval
- Direction
- testkit uses consumer.Consumer, so a change to consumer.Consumer can break testkit, while a change to testkit can't break consumer.Consumer.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
38→10 testkit uses testkit.Kafka✕
- Connections
- 1 pair of types, where a type in testkit uses a type in testkit.Kafka.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.testkit.Kafka.Sasl
- Direction
- testkit uses testkit.Kafka, so a change to testkit.Kafka can break testkit, while a change to testkit can't break testkit.Kafka.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
38→11 testkit uses admin.acl.AclOperation✕
- Connections
- 2 pairs of types, where a type in testkit uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.testkit.ZIOSpecWithKafka→zio.kafka.admin.acl.AclOperation.Any
- Direction
- testkit uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break testkit, while a change to testkit can't break admin.acl.AclOperation.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
38→19 testkit uses admin✕
- Connections
- 2 pairs of types, where a type in testkit uses a type in admin.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.admin.AdminClientzio.kafka.testkit.KafkaTestUtils→zio.kafka.admin.AdminClientSettings
- Direction
- testkit uses admin, so a change to admin can break testkit, while a change to testkit can't break admin.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
38→21 testkit uses admin.AdminClient.GroupType✕
- Connections
- 1 pair of types, where a type in testkit uses a type in admin.AdminClient.GroupType.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.admin.AdminClient.GroupType.Consumer
- Direction
- testkit uses admin.AdminClient.GroupType, so a change to admin.AdminClient.GroupType can break testkit, while a change to testkit can't break admin.AdminClient.GroupType.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
38→30 testkit uses consumer✕
- Connections
- 3 pairs of types, where a type in testkit uses a type in consumer.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.consumer.ConsumerSettingszio.kafka.testkit.KafkaTestUtils→zio.kafka.consumer.RebalanceListenerzio.kafka.testkit.KafkaTestUtils→zio.kafka.consumer.Subscription
- Direction
- testkit uses consumer, so a change to consumer can break testkit, while a change to testkit can't break consumer.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
38→34 testkit uses producer✕
- Connections
- 4 pairs of types, where a type in testkit uses a type in producer.
- The types involved
zio.kafka.testkit.KafkaTestUtils→zio.kafka.producer.Producerzio.kafka.testkit.KafkaTestUtils→zio.kafka.producer.ProducerSettingszio.kafka.testkit.KafkaTestUtils→zio.kafka.producer.TransactionalProducerzio.kafka.testkit.KafkaTestUtils→zio.kafka.producer.TransactionalProducerSettings
- Direction
- testkit uses producer, so a change to producer can break testkit, while a change to testkit can't break producer.
- Position
- Below the diagonal: testkit uses a module listed above it, which is the healthy direction.
39→11 bench uses admin.acl.AclOperation✕
- Connections
- 4 pairs of types, where a type in bench uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.bench.ZioBenchmark→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.bench.ZioKafkaConsumerBenchmark→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.bench.ZioKafkaProducerBenchmark→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.bench.ZioKafkaSeqProducerBenchmark→zio.kafka.admin.acl.AclOperation.Any
- Direction
- bench uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break bench, while a change to bench can't break admin.acl.AclOperation.
- Position
- Below the diagonal: bench uses a module listed above it, which is the healthy direction.
39→21 bench uses admin.AdminClient.GroupType✕
- Connections
- 1 pair of types, where a type in bench uses a type in admin.AdminClient.GroupType.
- The types involved
zio.kafka.bench.ZioKafkaConsumerBenchmark→zio.kafka.admin.AdminClient.GroupType.Consumer
- Direction
- bench uses admin.AdminClient.GroupType, so a change to admin.AdminClient.GroupType can break bench, while a change to bench can't break admin.AdminClient.GroupType.
- Position
- Below the diagonal: bench uses a module listed above it, which is the healthy direction.
39→38 bench uses testkit✕
- Connections
- 3 pairs of types, where a type in bench uses a type in testkit.
- The types involved
zio.kafka.bench.ZioKafkaConsumerBenchmark→zio.kafka.testkit.Kafkazio.kafka.bench.ZioKafkaProducerBenchmark→zio.kafka.testkit.Kafkazio.kafka.bench.ZioKafkaSeqProducerBenchmark→zio.kafka.testkit.Kafka
- Direction
- bench uses testkit, so a change to testkit can break bench, while a change to bench can't break testkit.
- Position
- Below the diagonal: bench uses a module listed above it, which is the healthy direction.
40→11 bench.comparison uses admin.acl.AclOperation✕
- Connections
- 3 pairs of types, where a type in bench.comparison uses a type in admin.acl.AclOperation.
- The types involved
zio.kafka.bench.comparison.ComparisonBenchmark→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.bench.comparison.KafkaClientBenchmarks→zio.kafka.admin.acl.AclOperation.Anyzio.kafka.bench.comparison.ZioKafkaBenchmarks→zio.kafka.admin.acl.AclOperation.Any
- Direction
- bench.comparison uses admin.acl.AclOperation, so a change to admin.acl.AclOperation can break bench.comparison, while a change to bench.comparison can't break admin.acl.AclOperation.
- Position
- Below the diagonal: bench.comparison uses a module listed above it, which is the healthy direction.
40→17 bench.comparison uses admin.AdminClient✕
- Connections
- 1 pair of types, where a type in bench.comparison uses a type in admin.AdminClient.
- The types involved
zio.kafka.bench.comparison.ComparisonBenchmark→zio.kafka.admin.AdminClient.TopicPartition
- Direction
- bench.comparison uses admin.AdminClient, so a change to admin.AdminClient can break bench.comparison, while a change to bench.comparison can't break admin.AdminClient.
- Position
- Below the diagonal: bench.comparison uses a module listed above it, which is the healthy direction.
40→30 bench.comparison uses consumer✕
- Connections
- 1 pair of types, where a type in bench.comparison uses a type in consumer.
- The types involved
zio.kafka.bench.comparison.ComparisonBenchmark→zio.kafka.consumer.ConsumerSettings
- Direction
- bench.comparison uses consumer, so a change to consumer can break bench.comparison, while a change to bench.comparison can't break consumer.
- Position
- Below the diagonal: bench.comparison uses a module listed above it, which is the healthy direction.
40→38 bench.comparison uses testkit✕
- Connections
- 1 pair of types, where a type in bench.comparison uses a type in testkit.
- The types involved
zio.kafka.bench.comparison.ComparisonBenchmark→zio.kafka.testkit.Kafka
- Direction
- bench.comparison uses testkit, so a change to testkit can break bench.comparison, while a change to bench.comparison can't break testkit.
- Position
- Below the diagonal: bench.comparison uses a module listed above it, which is the healthy direction.
40→39 bench.comparison uses bench✕
- Connections
- 1 pair of types, where a type in bench.comparison uses a type in bench.
- The types involved
zio.kafka.bench.comparison.ComparisonBenchmark→zio.kafka.bench.ConsumerZioBenchmark
- Direction
- bench.comparison uses bench, so a change to bench can break bench.comparison, while a change to bench.comparison can't break bench.
- Position
- Below the diagonal: bench.comparison uses a module listed above it, which is the healthy direction.
At a glance — Code Health
At a glance — Architecture
At a glance — Maturity
At a glance — Readiness
At a glance — Security
At a glance — Performance
Security & Compliance — OWASP Top-10 mapping
| OWASP category | Findings | Severity |
|---|---|---|
| A05:2025 — Injection | 66 | High / Critical |
| A03:2025 — Software Supply Chain Failures | 5 | Medium |
| A07:2025 — Authentication Failures | 4 | High / Critical |
Roadmap
First, establish a dedicated folder for Architecture Decision Records to formally document significant design choices and their consequences. Next, correct the README to accurately reflect the project's current state by removing claims about missing Docker files and microservices, and add a clear section on how to run the test suite. Finally, strengthen type safety by enabling explicit null checks in the build configuration and refactoring code to handle nulls safely at API boundaries.
| Do this | Helps | Effort | Dimension |
|---|---|---|---|
| Resolve the 1 No ADRs found finding(s) in ADR Quality. | +6.8 pts | Low | ADR Quality |
| Record your significant design decisions. Write one short document per decision, giving its date, the situation, the decision and its consequences, and keep them together with your other design documents. A docs/adr folder with each file named by number and title is the easiest place to find them. | +5.6 pts | Medium | Architecture documentation |
| Reconcile the README with reality: README claims a Docker-compose script for starting a Kafka broker but there is no docker-compose.yml file; README claims an embedded-kafka dependency not present in the evidence; README advertises Docker containerisation, but no Dockerfile/compose file exists; README advertises a microservices architecture, but the repo is a single project with no service manifests; docs/tutorial.md names `docker-compose.yml`, but no file or folder `docker-compose.yml` exists. | +4.7 pts | Medium | Documentation accuracy |
| Resolve the 1 Off-boarding risk finding(s) in Bus Factor. | +1.9 pts | Low | Bus Factor |
| Resolve the 2 Documentation finding(s) in Documentation Quality — start with index.md, writing-tests.md. | +1.7 pts | Low | Documentation Quality |
| Explain in the README how to run the tests. Add a section called Testing to the README in the repository's top folder, saying how to run the test suite. | +2.7 pts | Medium | Documentation (README) |
| On Scala 3, add `-Yexplicit-nulls` to `scalacOptions` so `String` and `String | Null` mean different things, and type each Java API's result as nullable where it can return null; on Scala 2 (or as a first step), enable WartRemover's `Null` wart (`wartremoverErrors += Wart.Null`) or Scalafix's `DisableSyntax.noNulls = true` so the code holds absence in `Option`. Then pay the assertions down rather than adding to them: each `.nn` is a null the compiler could not rule out — wrap the Java value in `Option(…)` at the boundary, pattern-match on `null` once there, or change the API so the null cannot arrive; an `unsafeNulls` import switches the checking off for everything after it. | +2.6 pts | Medium | Nullable reference types |
| Resolve the 13 REDACTED finding(s) in Static Analysis (SAST) — start with REDACTED (4), REDACTED (3), REDACTED (2). | +2.1 pts | Medium | Static Analysis (SAST) |
File quality
| File | Score | Band | Worst signal |
|---|---|---|---|
| REDACTED | 3.0 | Slop | Static Analysis (SAST): High: REDACTED |
| REDACTED | 4.4 | Mixed | REDACTED Scanning: Leaked secret: REDACTED |
| REDACTED | 4.4 | Mixed | REDACTED Scanning: Leaked secret: REDACTED |
| REDACTED | 4.4 | Mixed | Static Analysis (SAST): High: REDACTED |
| REDACTED | 4.4 | Mixed | Static Analysis (SAST): High: REDACTED |
| REDACTED | 4.4 | Mixed | Static Analysis (SAST): High: REDACTED |
| REDACTED | 4.5 | Mixed | Static Analysis (SAST): High: REDACTED |
| REDACTED | 4.8 | Mixed | Static Analysis (SAST): High: REDACTED |
| REDACTED | 4.8 | Mixed | Static Analysis (SAST): High: REDACTED |
| REDACTED | 5.8 | Mixed | Static Analysis (SAST): High: REDACTED |
| zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala | 7.0 | Mixed | Cyclomatic Complexity: Runloop.handlePoll (cyclomatic 34) |
| zio-kafka/src/main/scala/zio/kafka/consumer/internal/RebalanceCoordinator.scala | 7.4 | Mixed | Cyclomatic Complexity: RebalanceCoordinator.doAwaitStreamCommits (cyclomatic 24) |
| zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala | 7.4 | Mixed | Cyclomatic Complexity: ProducerLive.produceChunkAsyncWithFailures (cyclomatic 16) |
| zio-kafka/src/main/scala/zio/kafka/consumer/internal/LiveCommitter.scala | 7.4 | Mixed | Cognitive Complexity: LiveCommitter.commit (cognitive 21) |
| zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala | 7.8 | Mixed | Cyclomatic Complexity: PartitionStreamControl.newPartitionStream (cyclomatic 18) |
| zio-kafka/src/main/scala/zio/kafka/utils/SslHelper.scala | 7.8 | Mixed | Cyclomatic Complexity: SslHelper.doValidateEndpoint (cyclomatic 16) |
| zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala | 7.8 | Mixed | God Classes: FileTooLong: admin/AdminClient.scala |
| zio-kafka/src/main/scala/zio/kafka/producer/TransactionalProducer.scala | 8.5 | Near-clean | Cognitive Complexity: TransactionalProducer.make (cognitive 45) |
| zio-kafka/src/main/scala/zio/kafka/consumer/metrics/ZioMetricsConsumerMetricsObserver.scala | 8.5 | Near-clean | Cognitive Complexity: ZioMetricsConsumerMetricsObserver.observeRunloopMetrics (cognitive 43) |
| zio-kafka-bench/src/main/scala/zio/kafka/bench/ZioKafkaConsumerBenchmark.scala | 8.5 | Near-clean | Cognitive Complexity: ZioKafkaConsumerBenchmark.initialize (cognitive 21) |
How the grades work
A definite problem that already costs you something and drags the score down: a missing authorisation check, a dependency with a known exploit, a build that does not reproduce. Failure here tends to cause failures elsewhere.
Likely wrong, but not failing yet. It degrades the codebase over a longer horizon and can cause failures elsewhere — not urgent this week, not something to carry for two years either.
Recorded, with no effect on how the codebase functions. Present so the survey is complete, not because it needs doing.
Something this survey could not settle from the outside, and which could be critical or serious. Either a control was required and no positive evidence of it exists in the repository — a backup job that nothing shows was ever restored from proves nothing about restores — or our own analysis could not run over that part of the tree. This is not a clean result. These are excluded from the score rather than awarded a pass, so the number on the cover neither rewards nor penalises them: if you act on this survey without resolving them, you carry that risk yourself. Each one is named under Limitations.
Methodology & how to trust this report
Watchdog is a deep, periodic assessment — run each sprint, monthly, or quarterly, taking the time to go wider and deeper than a quick check and surfacing in one coherent report what you'd otherwise piece together from a dozen separate tools. It scores deterministically: the same commit yields the same score, every run. 59 of 63 evaluated dimensions are computed purely by tools and static analysis (confidence 1.0); 4 documentation/naming judgement(s) are LLM-assisted and labelled advisory. Overall confidence is 0.8 — the weighted average across measured dimensions; it falls as more of the score leans on LLM-assisted judgement and rises when it's fully tool-backed.
What we checked — 63 dimensions across the health lenses
- Can you open the finding? Real findings cite a repo-relative file and line you can open at the cited line — never an absolute scratch path. Here, 114 of 125 do; the remainder are repo-wide signals — a dimension-level measurement, not a single line.
- Is there a tool behind the number? Every score below names the method that produced it — Roslyn, git, a scanner, or (for a handful of documentation/naming dimensions) an LLM labelled sampled · advisory — not a narrative.
- Does re-running give the same result? Run it again on the same commit and the score — and this report, byte for byte — is identical. A report whose numbers move between runs is describing the run, not the code.
Tools & methods
| Method | Backs | Version | Evaluator |
|---|---|---|---|
| Roslyn static analysis | Complexity, cohesion, coupling, dead code, API surface, layering | 5.3.0 | ✓ deterministic |
| Native secret scanner | Hardcoded secrets / credentials | 1.0.0 | ✓ deterministic |
| Watchdog duplication detector (in-process) | Code duplication | 1.0.0 | ✓ deterministic |
| Coverage (coverlet / dotnet-coverage) | Line & branch coverage | 10.0.400 | ✓ deterministic |
| NuGet / dotnet | Outdated, vulnerable & deprecated dependencies | 10.0.400 | ✓ deterministic |
| git / LibGit2Sharp | Churn hotspots, knowledge concentration, history | 2.43.0 · 0.31.0 | ✓ deterministic |
| gitleaks · semgrep · trivy | Secrets in history, SAST, CVEs, IaC & container, PII / GDPR | 1.86.0 · 0.69.3 | ✓ deterministic |
| LLM (sampled · advisory) | Documentation quality, ADR conformance, naming — sampled over a bounded sample; advisory, never a deterministic measurement | Local LLM | ◐ LLM · sampled · advisory |
Run transparency — what happened this run
- D8 Code Coverage — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. Coverage NOT MEASURED: test source is present (.scala) but the built-in coverage collector has no runner for this repository's ecosystem — so this suite was never executed by it. Not scored — this is a gap in the analyzer's language coverage, not a defect in the repo. To have real coverage read, produce a coverage report in a standard format (`addSbtPlugin("org.scoverage" % "sbt-scoverage" % "<version>")` in `project/plugins.sbt`, then `sbt clean coverage test coverageReport`) and commit it — a hosted scan measures a clone of the repository, so a report that exists only in a working tree, a CI runner's or your own, never reaches it; the artefact is commonly gitignored, so `git add -f` that one file (or un-ignore its path) and commit it alongside the code it measures. You can widen what we reach: optional: produce a coverage report in a standard format (`addSbtPlugin("org.scoverage" % "sbt-scoverage" % "<version>")` in `project/plugins.sbt`, then `sbt clean coverage test coverageReport`) and commit it — a hosted scan measures a clone of the repository, so a report that exists only in a working tree, a CI runner's or your own, never reaches it; the artefact is commonly gitignored, so `git add -f` that one file (or un-ignore its path) and commit it alongside the code it measures — then the real number is read on the next scan.
- D11 Test Reliability — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. Test source is present (.scala) and this repository declares an sbt build (repository root, 28 test files), but it was not re-run: the analyzer environment could not run it. Not scored — this is a gap in the analyzer's language coverage, not a finding about this repository.
- D14 License Compliance — measured, with a gap in what it reached — Watchdog measured this, but not all of it. What it did not reach is a gap on our side — a collector, parser or image we have not built yet — so the numbers on that dimension cover less than the repository, and the part left out is not evidence that it would have passed. This repository declares package.json, but the licence verdict published here was taken over its sbt dependencies. Nothing was read about its npm dependencies' licensing in either direction, and a clean score on this card must not be read as covering them.
- D22 Internal API Consistency — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. D22 identifies the intentionally-exposed surface from `IsPackable` and `.Contracts` project names, MSBuild conventions read off the loaded project set. This target exposed no such projects, so the probe never ran; this says nothing about whether the repository has a public API. This repository commits no C#/VB source at all, so there was never an MSBuild project set to read these conventions off. That is OUR side and it is an ADMISSION gap, not an environment fault: no published-package marker D22 reads admitted any project here. D22 DOES collect the public API of every language in this tree, and admits a project only when its manifest makes that ecosystem's publication act in a form the marker recognises — so what is missing is not a collector but an admission rule for the publication act this repository makes, if it makes one. The remedy is a better discriminator for that marker — not a collector, and no change to the scan image can close it. The marker's rules are measured to refuse applications, so one refused repository is the rule working as calibrated; several are the evidence that it is too strict. For npm the surface is what a published package.json's entry points (exports, main, module, types) export, followed through the source; an entry that names build output the tree does not commit (dist/, build/) is not followed back to source, because only a tsconfig outDir/rootDir pair states that mapping and a bundler's input lives in executable configuration this engine does not evaluate.
- D27 Navigability — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. Navigability is taken over call sites whose callee resolved. For C# that population includes calls into referenced assemblies; for this language only calls declared inside the repository count, so the abstention threshold reads the repository's use of its standard library as a resolution failure. That is a limit of this analyzer, not a build problem in this repository.
- D34 Knowledge Freshness — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. File-level freshness contradicts repo activity: 41 commits in the last 90 days, yet 20 of 36 significant files carry no living knowledge. Those two readings cannot both be true, so the per-file recency signal is treated as unreliable here and freshness is not scored for this run.
- D44 Platform End-of-Life — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. This dimension reads a project's own statement about the platform it runs on: a TargetFramework in a .NET project file, a .nvmrc or .python-version, a capped requires-python, a Rust toolchain file or Cargo.toml rust-version, a .go-version, .java-version, .ruby-version, .tool-versions or .sdkmanrc, a go.mod go directive, a Maven or Gradle Java level or toolchain, a Gemfile's ruby directive, a mix.exs elixir requirement, a rebar.config minimum_otp_vsn, a pubspec.yaml SDK constraint, a build.sbt scalaVersion, or a framework major pinned by a dependency constraint. This repository carries none of them, so nothing about its platform was established. That is a gap in this analyzer's coverage, NOT a finding that the platform is supported — a language whose runtime is declared elsewhere (Package.swift, a Dockerfile) is simply not read here yet.
- C1 Data Protection — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. These personal data controls are read from declarative annotations, request middleware, entity/column names and guard methods in a C# source model, and none was loaded on this run, so there was nothing to gather. That is a gap in this analyzer's language reach — not a finding that the repository lacks personal data controls.
- C2 Access Controls — not measured this run — Watchdog could not measure this here. That is a gap on our side — a collector, parser or image we have not built yet — and it is neither a defect in this repository nor evidence that the check would have passed. These authorization controls are read from declarative annotations, request middleware, entity/column names and guard methods in a C# source model, and none was loaded on this run, so there was nothing to gather. That is a gap in this analyzer's language reach — not a finding that the repository lacks authorization controls.
- P5 DR & Backup — not measured this run — This is a true statement about the repository that carries nothing for its owner to act on, so it is reported here rather than as a defect in their code. No backup/snapshot/replication config, RTO/RPO or restore-procedure documentation was found — and no production persistence was detected either (no data-access packages, no data-store services, no database resources), so there is nothing in this repository whose loss a DR control would recover. If this system's data lives in a platform or ops repo we can't see, that's where the DR evidence belongs.
Limitations & what we did not check
Watchdog assesses the repository exactly as committed, and only the repository. By design it does not reach outside the source tree: the live cloud account, the running CI/CD pipeline, the host's branch-protection and approval rules, the production configuration, or a restore actually exercised against a backup are all out of scope. That boundary is a feature, not a gap — a repo-relative, deterministic scan re-runs identically on any commit and every finding opens at a real file and line, where a live audit can neither be reproduced nor traced. The visible consequence is that controls which leave no in-repo evidence are reported as "not evidenced" and excluded from the score rather than awarded a number a static scan cannot justify.
Per-dimension blind spots
- D1 Cyclomatic Complexity: Cyclomatic complexity counts branches statically — it cannot tell an essential decision tree from accidental tangle, nor see complexity that lives in data or configuration (large switch-case token tables, DSL lexers/parsers, data-as-code rule tables) rather than control flow: a tokenizer's many single-character cases read as high complexity though each branch is trivial.
- D2 Cognitive Complexity: Cognitive-complexity heuristics approximate how hard code is to follow; genuine domain difficulty and well-named intent that eases reading are not captured.
- D3 God Classes: "God class" is sized by members and responsibilities visible in the type — a deliberately broad facade over a coherent subsystem can read the same as an accidental grab-bag. For front-end JS the file-length check is cohesion-aware (a single-responsibility module — one class/IIFE — earns a 3× threshold), but cohesion is approximated from top-level declarations, not true dependency structure.
- D4 Code Duplication: Duplication is token-similarity — an in-process token-stream comparison over sliding windows, with type-aware normalization — so it finds copy-paste, not semantic duplication expressed differently. Committed machine-written code (scaffolded migrations, designer/codegen output, protobuf/OpenAPI stubs, model snapshots) is EXCLUDED — its repetition is the tool's, not the team's — so the score reflects hand-written duplication only.
- D5 Coupling: Coupling is measured between projects/assemblies — runtime coupling through DI, reflection, messaging or shared databases is invisible to a static reference graph.
- D6 Cohesion (LCOM4): LCOM4 cohesion is syntactic — it infers connectivity from which methods touch which fields/methods by name, not from real runtime behaviour or intent.
- D9 Test Distribution: The test-pyramid shape is inferred from project/folder naming and references, with a single test host bucketed per-file by its path tier and content signals — a suite that names tiers unconventionally and gives no per-file signal can still be mis-bucketed.
- D12 Dependency Hygiene: Dependency health reads manifests and lockfiles — a vulnerability in a vendored/copied dependency, or risk from how a dependency is actually used, is outside this view.
- D13 REDACTED Scanning: REDACTED detection is signature- and entropy-based on the current tree — a secret that does not match a known pattern, or one already rotated, will not be flagged (a clean scan is "nothing matched", not "no secrets exist").
- D14 License Compliance: License compatibility is checked against declared package metadata and a policy — mislabelled or missing license metadata, and obligations that depend on how you distribute, are not resolved here.
- D15 Churn × Complexity Hotspots: Churn hotspots come from git history — a freshly imported or squashed repository has no churn signal, and recent rewrites can mask a historically risky file.
- D16 Bus Factor: Bus-factor is a time-decayed model of commit attribution (who has recently, repeatedly worked a file), not comprehension — pairing, review and reading-without-committing spread knowledge it can't see; bot commits and shared accounts still distort it.
- D17 Explicit Debt: Acknowledged-debt signals (TODO/FIXME, suppressions, dead code) are textual — undocumented debt that nobody marked, and debt that lives in design rather than annotations, is invisible. Committed machine-written code (scaffolded migrations, designer/codegen output, generated stubs) is excluded — it is never the team's dead code to delete.
- D19 Documentation Quality: Documentation quality is judged by an LLM over a bounded sample of docs — it reads what is written, not whether the docs match the running system, and it is advisory, not a measurement. Its critique rows are drawn from a closed category vocabulary and each row means the same thing in every run, so two scans can be compared row by row; the SET that fires is still a sample, and does not repeat exactly. Measured on one frozen input, six scans at one engine SHA: 2-5 critique rows per scan, 8 distinct rows across the six, 3 of those 8 seen in only one scan. So a D19 row is evidence about the documentation, but a COUNT of D19 rows is not a quantity — never read a change in it as an improvement or a regression.
- D20 ADR Quality: ADR quality is an LLM read of the decision records present — it cannot know about decisions made and never recorded, and its verdict is sampled and advisory.
- D21 Naming Consistency: Naming quality is an LLM judgement over a bounded sample — it assesses clarity/consistency of the names it sees, not domain-correctness, and is advisory.
- D26 Project Cohesion: Project focus is sized from members/namespaces per project — a project that is broad by deliberate design reads the same as one that has sprawled.
- D28 Secrets (history): Secret-history scanning sweeps the git log for known patterns — a secret that predates the available history, or never matched a signature, is not found (clean means "nothing matched in the history we can see").
- D29 Static Analysis (SAST): SAST findings are pattern-based (semgrep) — it finds classes of bug it has rules for; logic flaws, auth/authorization gaps and issues needing runtime context are out of reach (and clean means "no rule matched").
- D30 Dependency Vulnerabilities: CVE matching depends on accurate package/version metadata and on the advisory databases — a vulnerability with no published advisory, or in code not declared as a dependency, is not seen. Coverage needs a RESOLVED graph: an unpinned requirements.txt, or a pom without a resolved build, yields partial coverage rather than a clean verdict. An ecosystem the analyzer cannot scan is reported as unmeasured, never as clean.
- D35 Change Coupling: Change coupling is co-change in COMMITS — files split across separate commits, or coupled only through a shared config/build step, read as uncoupled, and a sweeping commit (rename/format) is excluded so it doesn't couple everything. It shows that files change together, not WHY: a high coupling can be a healthy cohesive pair as readily as a hidden leak.
- D43 Malicious Dependencies: Only packages some vulnerability database has already NAMED as malicious are seen — a compromise published in the last hours, or never reported at all, is invisible here, and this dimension reading 10 is not evidence that a dependency is trustworthy. There is no typosquat or dependency-confusion analysis: a package nobody has reported is simply absent from the feeds. Coverage is the dependency scan's: an ecosystem that could not be scanned is disclosed as unmeasured, never as clean.
- AX10 Code composition: Role is inferred from namespace/folder convention, not semantics — a domain concept living in a folder named "Services" reads as application, and the split is lines-of-code, not business value. The business-logic-share score is a SOFT, FLOORED signal: it contributes to the Architecture lens but is floored at the Critical gate, so an infrastructure-heavy design (a gateway, an ETL, a driver) is legitimately low without being nuked to zero.
- M4 Documentation accuracy: Onboarding quality is an LLM read of the docs/setup present — it cannot run the onboarding or measure how long a real new joiner takes; the verdict is sampled and advisory.
- P4 Deployment & Rollback: Approval/branch-protection rules live in repository settings the scan cannot see — only their in-repo evidence (config files, workflows) is checked, so a control enforced purely in the host's settings reads as "not evidenced".
- P6 Release Hygiene: Rollback/observability controls are inferred from repo artefacts (pipelines, dashboards-as-code) — controls configured in external tooling, with no in-repo trace, cannot be credited.
The LLM boundary
Dimensions
D1 · Cyclomatic Complexity
6 method(s) exceeded the cyclomatic complexity threshold of 15; the worst was Runloop.handlePoll at 34. A further 1 method(s) were over the threshold but excluded as flat dispatchers (a long switch/match over independent cases: many branches, almost no nesting), the largest being AclOperation.apply at 17 — they are counted neither in the figure above nor in this dimension's score. 1 file carries no cyclomatic complexity row at all for this reason — every one of its over-threshold methods was excluded, so the exclusion is disclosed nowhere in the file itself: zio-kafka/src/main/scala/zio/kafka/admin/acl/AclOperation.scala (AclOperation.apply at 17). They are named here because the per-file figures other dimensions report are taken BEFORE this exclusion, so such a file can show a high maximum complexity elsewhere in this report and nothing here, with nothing to reconcile the two.
What to do
- Bring the 6 bodies over 15 down to 15 or less in Cyclomatic Complexity — start with Runloop.handlePoll (cyclomatic 34), Runloop.handleCommand (cyclomatic 25), RebalanceCoordinator.doAwaitStreamCommits (cyclomatic 24). — This score is capped by its worst body, so a finding fixed alone moves it by almost nothing — the next one down takes its place. Refactoring these 6 together lifts Cyclomatic Complexity from 8.7 to about 10.0/10, projected with the scoring formula itself and assuming each lands exactly at 15.
- Enforce Cyclomatic Complexity in CI to reach Verified (currently Documented). — Hardens enforcement from Documented toward Prevented — provenance only; does not change the score.
D2 · Cognitive Complexity
18 method(s) exceeded the cognitive complexity threshold of 15; the worst was Runloop.handlePoll at 304.
What to do
- Bring the 1 body over 120 down to 120 or less in Cognitive Complexity — start with Runloop.handlePoll (cognitive 304). — Refactoring it lifts Cognitive Complexity from 4.5 to about 5.7/10.
- Enforce Cognitive Complexity in CI to reach Verified (currently Documented). — Hardens enforcement from Documented toward Prevented — provenance only; does not change the score.
D3 · God Classes
2 over-large unit(s) detected — types, modules or files that carry too much.
What to do
- Resolve the 2 FileTooLong finding(s) in God Classes — start with AdminClient.scala, Runloop.scala. — One of this dimension's main actionable groups (2 warning-level).
- Enforce God Classes in CI to reach Verified (currently Documented). — Hardens enforcement from Documented toward Prevented — provenance only; does not change the score.
D4 · Code Duplication
4 duplicated block group(s) detected.
What to do
- Resolve the 1 Duplicated block (18–19 lines × 2) finding(s) in Code Duplication — start with Kafka.scala. — One of this dimension's main actionable groups (1 warning-level).
- Resolve the 1 Duplicated block (10–11 lines × 2) finding(s) in Code Duplication — start with AdminClient.scala. — One of this dimension's main actionable groups (1 warning-level).
- Resolve the 1 Duplicated block (10 lines × 2) finding(s) in Code Duplication — start with Consumer.scala. — One of this dimension's main actionable groups (1 warning-level).
- Enforce Code Duplication in CI to reach Verified (currently Documented). — Hardens enforcement from Documented toward Verified — provenance only; does not change the score.
D5 · Coupling
4 production modules (sbt), 0 dependency cycle(s), 0 unstable depended-on module(s). Read from the build's own module declarations; a dependsOn spread (deps: _*) and a project whose directory a helper computes are not visible there; 1 module(s) off the main sequence, with abstractness counted on 2 of the 4 (the rest declare no modelled class or interface, export only macros, declare types in source no model reads, or have no source directory of their own).
What to do
- Resolve the 1 Off the main sequence finding(s) in Coupling. — One of this dimension's main actionable groups (1 warning-level).
- Enforce Coupling in CI to reach Verified (currently Documented). — Hardens enforcement from Documented toward Prevented — provenance only; does not change the score.
D6 · Cohesion (LCOM4)
0 of 4 classes have LCOM4 above 3.
D9 · Test Distribution
196 test methods: 196 unit, 0 integration, 0 BDD, 0 e2e. The Scala suite contributes 196 test case(s) across 24 file(s) in a test source set declaring at least one — every `test("…")`, `it("…")`, `property("…")` and `"…" in {…}` registration and every JUnit `@Test`, which is how munit, ScalaTest, utest, ZIO Test and specs2 declare a case; a case registered under a computed name is not counted, so this is a floor. Its tier split is INFERRED from paths and file names, except sbt's src/it source set, which the build declares.
D12 · Dependency Hygiene
1 outdated direct sbt declarations. An sbt declaration names an EXACT version, so the remedy is an edit to the build file — there is no lockfile refresh that would move it. Test-, Provided- and it-scoped declarations are excluded, because a consumer of this project never receives them. A version held in a Scala val is read only when the val is one string literal: sbt is a program rather than a manifest, and evaluating a computed version would invent the measurement rather than take it. Whether any artifact is DEPRECATED or ABANDONED is not graded and cannot be — Maven Central publishes no such marker, and release age does not stand in for one: the most widely depended-upon libraries are routinely the stalest, being finished rather than abandoned. Known CVEs in this dependency graph are D30's question.
D13 · REDACTED Scanning
2 secret(s) detected.
What to do
- Resolve the 2 Leaked secret finding(s) in REDACTED Scanning — start with REDACTED, REDACTED. — One of this dimension's main actionable groups (2 issue-level).
- Enforce REDACTED Scanning in CI to reach Verified (currently Documented). — Hardens enforcement from Documented toward Prevented — provenance only; does not change the score.
D14 · License Compliance
0 of 8 declared sbt dependency artifact(s) use a banned license. Licences were resolved from the POMs Maven Central publishes, over the production coordinates this repository's 2 sbt build file(s) (build.sbt and project/*.scala) declare with a literal version, directly or through a string-literal val — `%%` resolved to the Scala binary suffix Central publishes under, test-scoped declarations excluded — the same declaration-site closure this analysis reads for dependency currency. sbt has no lockfile a checkout carries, so this is deliberately NOT the transitive closure. 2 further production coordinate(s) are declared with a version the build computes rather than writes as a literal — sbt is a program, and this pass does not run it — and are NOT graded: this verdict covers what the build pins literally or through a string-literal val, not the full graph. ★ COVERAGE OF THIS VERDICT: it grades this repository's sbt dependencies and nothing else. The repository also declares package.json, and the licences of those dependencies were NOT read by this pass — a gap in this engine's coverage, not a statement about them. So this result says the graded closure carries no banned licence; it does NOT say this repository's licensing is clear.
D15 · Churn × Complexity Hotspots
No churn × complexity hotspots in the window.
D16 · Bus Factor
3 source file(s) have their living knowledge concentrated in one author (≥90% of recent, decayed contribution). The largest is zio-kafka-testkit/src/main/scala/zio/kafka/testkit/KafkaTestUtils.scala. Counted over 36 of the 82 production source files in this repository: the rest are under the ~2,400-byte size floor this dimension measures over.
D17 · Explicit Debt
0 deducted task-comment markers across 8811 LoC (0.0/KLoC) → score 10.0. Task comments only: this repository's language is read without a compiler, so D17's suppression, dead-code and commented-out-code arms did not run and this score counts fewer marker kinds than a .NET repository's would.
D19 · Documentation Quality
The repository's root README (ZIO Kafka) is excellent at conveying what the project does and its stage, plus a strong CI/Sonatype badge section. The zio-kafka-bench/README documents the benchmarks directory, not the repo, so it is an internal-directory README with no cross-referencing to the root. docs/avoiding-chunk-breakers.md is a focused architecture doc that explains chunk-breaking operators and their alternatives (mapZIOChunked/chunksWith), plus side-effect-per-chunk options, and ends with a clipped 'Expose chunking structure with chunks; Side effects per chunk with tapChunks; Avoid rechunk'. docs/consumer-tuning.md covers tuning via ConsumerSettings for throughput, latency, memory, and long-running processes, plus the two similarly-named pollTimeout/max.poll.interval.ms settings. docs/consuming-kafka-topics-using-zio-streams.md is a runnable example of plainStream with tap/mapZIO/aggregateAsyncWithin, plus a caution about chunk-breakers. docs/detecting-authorization-failures.md explains the metadata-refresh probe for silent authorization loss detection. The only unshown document in the set is the architecture/design doc (the one clipped), so its sections are present and not flagged. This repository's documentation is comprehensive: the README (and its sibling tutorial.md) gives a clear overview of what ZIO Kafka does and where to find installation, usage, contribution, and license information. The architecture/design docs are well written with detailed sections on metrics, migration from zio-kafka 2.x, partition assignment, preventing duplicates, serialization/deserialization, transactions, and a full tutorial showing how to run the examples. This is a well-written README for the zio-kafka-testkit library that explains what it does and gives concrete installation and test code. It opens with an overview of the project ("Zio-kafka provides a `zio-kafka-testkit` library to help you test your code using zio-kafka") plus a short dependency line, then dives into testing a producer example with a mdoc shell block that shows how to create a Kafka producer and assert it completes. The document is well-structured with an outline of topics yet to be clipped (Producer layer; More Kafka sharing options; Considerations for sharing Kafka between tests; Testing a consumer; ...).
What to do
- Resolve the 2 Documentation finding(s) in Documentation Quality — start with index.md, writing-tests.md. — One of this dimension's main actionable groups (2 recommendation-level).
D20 · ADR Quality
No architecture decision records were found.
What to do
- Resolve the 1 No ADRs found finding(s) in ADR Quality. — One of this dimension's main actionable groups (1 recommendation-level).
D21 · Naming Consistency
0 naming inconsistencies across 0 sampled symbols.
D26 · Project Cohesion
1 of 1 build units (sbt) flagged as possibly oversized/incoherent.
What to do
- Resolve the 1 Projects may be oversized for their cohesion finding(s) in Project Cohesion. — One of this dimension's main actionable groups (1 recommendation-level).
D28 · Secrets (history)
2 finding(s): 0 critical, 2 high, 0 medium, 0 low.
What to do
- Resolve the 1 High secret finding(s) in Secrets (history) — start with REDACTED. — One of this dimension's main actionable groups (1 issue-level).
- Resolve the 1 REDACTED finding(s) in Secrets (history) — start with REDACTED. — One of this dimension's main actionable groups (1 issue-level).
D29 · Static Analysis (SAST)
66 finding(s): 0 critical, 66 high, 0 medium, 0 low. 51 unpinned-GitHub-Actions row(s) are reported here but scored by D36 (supply-chain provenance), which measures that posture as `pinned_actions` — one pinning decision is charged once, not once per lens. Separately, one or more rules could not re-parse an embedded snippet in 1 file(s) (e.g. a workflow `run:` block read as shell). Those files WERE scanned and their other rows are unaffected; only those rules' view of those snippets is missing.
What to do
- Resolve the 13 REDACTED finding(s) in Static Analysis (SAST) — start with REDACTED (4), REDACTED (3), REDACTED (2). — One of this dimension's main actionable groups (13 issue-level).
- Resolve the 1 REDACTED finding(s) in Static Analysis (SAST) — start with REDACTED. — One of this dimension's main actionable groups (1 issue-level).
- No action in Static Analysis (SAST) — all 51 REDACTED finding(s) are reported here at file:line but scored by D36 (supply-chain provenance), so none is charged to this dimension. — One of this dimension's main actionable groups (51 issue-level, 0 of them charged here).
D30 · Dependency Vulnerabilities
No known-vulnerable dependencies in any ecosystem this repository declares.
D35 · Change Coupling
Strongest change-coupling: Offset.scala↔Runloop.scala 50%
What to do
- Resolve the 1 Change coupling finding(s) in Change Coupling — start with Offset.scala. — One of this dimension's main actionable groups (1 warning-level).
D36 · Supply-chain Provenance & Signing
1/4 supply-chain integrity signals present (provenance, signing, SBOM, pinned actions).
What to do
- Resolve the 1 REDACTED finding(s) in Supply-chain Provenance & Signing. — One of this dimension's main actionable groups (1 warning-level).
- Resolve the 1 REDACTED finding(s) in Supply-chain Provenance & Signing — start with REDACTED. — One of this dimension's main actionable groups (1 warning-level).
- Resolve the 1 REDACTED finding(s) in Supply-chain Provenance & Signing. — One of this dimension's main actionable groups (1 warning-level).
D43 · Malicious Dependencies
No dependency in any ecosystem this repository declares is published as malicious.
Frontend & cross-cutting dimensions
AX10 · Code composition
What to do
- The domain core is a small share of production code, but most of the rest matched no layer vocabulary at all — so this is not yet an anemic-domain finding. The namespace/path convention could not place that code, which makes the composition above a statement about the naming, not about the design. Name the layers (or check that the repository's conventions differ from the ones this check knows) before reading a thin domain into it.
AX3 · Project dependency cycles
AX4 · Dependency direction
AX6 · Interface segregation
- `AdminClient` declares 37 abstract members: `createTopics`, `createTopic`, `deleteConsumerGroups`, `deleteTopics`, `deleteTopic`, `deleteRecords`, `listTopics`, `describeTopics`, `describeConfigs`, `describeConfigsAsync`, `describeClusterNodes`, `describeClusterController`, `describeClusterId`, `describeClusterAuthorizedOperations`, `createPartitions`, `listOffsets`, `listOffsetsAsync`, `listConsumerGroupOffsets`, `listConsumerGroupOffsets`, `listConsumerGroupOffsets`, `alterConsumerGroupOffsets`, `metrics`, `listConsumerGroups`, `listGroups`, `describeConsumerGroups`, `describeConsumerGroups`, `removeMembersFromConsumerGroup`, `removeAllMembersFromConsumerGroup`, `describeLogDirs`, `describeLogDirsAsync`, `incrementalAlterConfigs`, `incrementalAlterConfigsAsync`, `describeAcls`, `createAcls`, `createAclsAsync`, `deleteAcls`, `deleteAclsAsync`. Counted over its ABSTRACT members — a `def` with no body or a `val`/`var` with no initializer, once per signature; concrete members, private and protected members, and members of a companion `object` are not counted, because no implementer is forced to write them. Those 37 declarations carry 34 distinct name(s), so part of the width is overloading rather than separate responsibilities — but 34 operations clears the >15 bar on its own, so the row is about responsibilities, not signatures. A wide interface forces every implementer and caller to depend on methods they don't use (the Interface-Segregation 'I' in SOLID). Split it into focused role-interfaces. — zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala:82
- `Consumer` declares 20 abstract members: `assignment`, `beginningOffsets`, `consumerSettings`, `endOffsets`, `committed`, `listTopics`, `partitionedAssignmentStream`, `partitionedStream`, `plainStream`, `plainStreamWithControl`, `partitionedStreamWithControl`, `partitionedAssignmentStreamWithControl`, `stopConsumption`, `consumeWith`, `offsetsForTimes`, `partitionsFor`, `position`, `subscription`, `metrics`, `registerExternalCommits`. Counted over its ABSTRACT members — a `def` with no body or a `val`/`var` with no initializer, once per signature; concrete members, private and protected members, and members of a companion `object` are not counted, because no implementer is forced to write them. A wide interface forces every implementer and caller to depend on methods they don't use (the Interface-Segregation 'I' in SOLID). Split it into focused role-interfaces. — zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala:22
What to do
- Split fat interfaces into focused role-interfaces so clients depend only on what they use.
AX8 · Test isolation
GD1 · Unfinished & placeholder code
IC1 · Incompleteness & stubs
M1 · Documentation (README)
What to do
- Explain in the README how to run the tests. Add a section called Testing to the README in the repository's top folder, saying how to run the test suite.
- Add an 'Architecture' / 'How it works' section to the root README — the high-level shape.
- Add a README to the 1 of 1 project(s) that lack one — worth up to 2 pts.
M2 · Architecture documentation
- No Architecture Decision Records found — no conventional ADR directory, no numbered `NNNN-title` documents in any markup this check reads, and nothing ADR-shaped by content. Design rationale recorded elsewhere (a design-notes tree, a mailing list, pull-request discussion) is not visible to this check and is not re-findable per decision, so a future maintainer cannot ask why one choice was made and get an answer.
What to do
- Record your significant design decisions. Write one short document per decision, giving its date, the situation, the decision and its consequences, and keep them together with your other design documents. A docs/adr folder with each file named by number and title is the easiest place to find them.
M3 · Folder & project structure
M4 · Documentation accuracy
- README claims a Docker-compose script for starting a Kafka broker but there is no docker-compose.yml file — searched for: `docker-compose`. Each was matched case- and separator-insensitively against file and directory NAMES anywhere in the tree, and against the CONTENTS of manifest and configuration files (package.json and other *.json, *.csproj, *.props, *.sln/*.slnx, *.yml, *.toml, *.config, tool configs such as eslint.config.js, Dockerfile); the README's own prose never counts, so a claim is never refuted by merely being made. Nothing outside that search was read — a footprint living only in a submodule, in a file type not listed here, or under a name none of those terms matches is not seen, and this row is then wrong. — README.md:1
- README claims an embedded-kafka dependency not present in the evidence — searched for: `embedded-kafka`. Each was matched case- and separator-insensitively against file and directory NAMES anywhere in the tree, and against the CONTENTS of manifest and configuration files (package.json and other *.json, *.csproj, *.props, *.sln/*.slnx, *.yml, *.toml, *.config, tool configs such as eslint.config.js, Dockerfile); the README's own prose never counts, so a claim is never refuted by merely being made. Nothing outside that search was read — a footprint living only in a submodule, in a file type not listed here, or under a name none of those terms matches is not seen, and this row is then wrong. — README.md:1
- README advertises Docker containerisation, but no Dockerfile/compose file exists — searched for: `dockerfile`, `docker-compose`, `compose.yaml`, `compose.yml`. Each was matched case- and separator-insensitively against file and directory NAMES anywhere in the tree, and against the CONTENTS of manifest and configuration files (package.json and other *.json, *.csproj, *.props, *.sln/*.slnx, *.yml, *.toml, *.config, tool configs such as eslint.config.js, Dockerfile); the README's own prose never counts, so a claim is never refuted by merely being made. Nothing outside that search was read — a footprint living only in a submodule, in a file type not listed here, or under a name none of those terms matches is not seen, and this row is then wrong. — README.md:75
- README advertises a microservices architecture, but the repo is a single project with no service manifests — searched for: `microservice`, `service-mesh`, `istio`. Each was matched case- and separator-insensitively against file and directory NAMES anywhere in the tree, and against the CONTENTS of manifest and configuration files (package.json and other *.json, *.csproj, *.props, *.sln/*.slnx, *.yml, *.toml, *.config, tool configs such as eslint.config.js, Dockerfile); the README's own prose never counts, so a claim is never refuted by merely being made. Nothing outside that search was read — a footprint living only in a submodule, in a file type not listed here, or under a name none of those terms matches is not seen, and this row is then wrong. — README.md:173
- docs/tutorial.md names `docker-compose.yml`, but no file or folder `docker-compose.yml` exists. Checked without a model against the repository: its files and folders, the scripts and dependencies of every package.json, the projects, namespaces, package references and target frameworks of the .NET build, the SDK and Node pins, and the identifiers of every file that is not a document; the documents' own text never counts. A footprint generated at build time, read only by a platform, or living outside this repository is not seen, and this row is then wrong. — docs/tutorial.md:49
What to do
- Reconcile the README with reality: README claims a Docker-compose script for starting a Kafka broker but there is no docker-compose.yml file; README claims an embedded-kafka dependency not present in the evidence; README advertises Docker containerisation, but no Dockerfile/compose file exists; README advertises a microservices architecture, but the repo is a single project with no service manifests; docs/tutorial.md names `docker-compose.yml`, but no file or folder `docker-compose.yml` exists.
P1 · CI/CD gates
P3 · Security & performance tooling
What to do
- Your ecosystem's static analyzer is declared as a dependency but is not wired into CI — run it as a required step on push/PR (e.g. `composer phpstan` / `mix sobelow` / `bundle exec brakeman` / the spotbugs Gradle task / `sbt scalafixAll --check` / `golangci-lint run` / `rebar3 lint`) so a regression fails the build instead of relying on someone running it locally.
- Dependabot is configured but does not watch `npm` — add that `package-ecosystem` entry to .github/dependabot.yml so those dependencies get the same automatic update and advisory pressure as the ones it already covers.
- Add gitleaks/trufflehog in CI to block PRs that introduce committed secrets.
P4 · Deployment & Rollback
What to do
- Nothing pauses a release for a human: publish as a draft release (or gate the release job on a protected tag/manual dispatch) so a bad build can be stopped before users can download it.
P6 · Release Hygiene
PF1 · Benchmark discipline
- A JMH/Jetpack Benchmark suite exists but nothing turns on its allocation measurement — allocations (the main way hot code pressures a garbage collector or allocator) aren't being measured. — zio-kafka-bench/src/main/scala/zio/kafka/bench/ZioKafkaSeqProducerBenchmark.scala
What to do
- Run JMH with the GC profiler (`-prof gc`, or addProfiler(GCProfiler.class)) so allocation rate regressions are visible, not just time.
PF2 · Allocation hygiene
What to do
- Raise allocation-aware density on the hot paths — currently 23 use(s) across 9,345 production line(s) (~2.5/1k). More of the idioms below on the allocation-heavy paths climbs this toward 10.
- Scala: on hot paths, make small wrappers value classes (extends AnyVal), @specialized generic code over primitives, use primitive collections, and presize builders.
PF3 · Async & latency hygiene
- `blockingSleep` is async and calls Thread.sleep — a blocking call inside async code stalls the execution-context thread, and every future or fiber scheduled on it for as long as it runs. — zio-kafka/src/main/scala/zio/kafka/consumer/internal/package.scala:36
What to do
- Scala: compose the Future or effect (map/flatMap, a for-comprehension) instead of Await.result or unsafeRunSync, and wrap unavoidable blocking calls in blocking { } (Future), IO.blocking or ZIO.attemptBlocking.
X1 · Async correctness
X12 · Unreachable branch
X13 · Undrained process stream
X14 · Bypassable address classification
X15 · Unvalidated length from an untrusted reader
X16 · Unfloored truncation loop
X17 · Uncapped recursion over a caller-supplied document
X18 · Disposal-pattern correctness
X19 · Unrestored process-global state
X20 · Mistyped argument guard
X21 · Side-effecting pattern guard
X22 · Contradicted release guard
X23 · Unguarded diagnostic materialisation
X24 · Document value interpolated into markup unescaped
X25 · Inert configuration knob
X26 · Unsynchronised callback handoff
X27 · Collection changed while being enumerated
X28 · Index access outside its own emptiness guard
X29 · Per-element action decided by a fixed element
X3 · Exception handling
- `case NonFatal(_)` takes every exception and records none of it — the body neither logs it, rethrows it, nor even names it, so the failure is discarded as completely as by an empty catch and only the substituted value survives. Log it through whatever this codebase already uses to report problems, narrow the catch to the exception this call can actually raise, or say in a comment on the catch why the failure genuinely cannot matter. — zio-kafka/src/main/scala/zio/kafka/utils/SslHelper.scala:54
What to do
- Swallowed exception (caught, then discarded)
X30 · Support guard that admits what it rejects
X5 · Nullable reference types
- No build over this repository's 75 Scala product file(s) passes `-Yexplicit-nulls`, enables WartRemover's `Null` wart or runs Scalafix's `DisableSyntax.noNulls`, so every reference type admits null and nothing reports a `null` written into the code or returned from a Java API — the first one to reach a method call is a `NullPointerException`. `Option` by convention is a habit no tool here holds the code to.
What to do
- On Scala 3, add `-Yexplicit-nulls` to `scalacOptions` so `String` and `String | Null` mean different things, and type each Java API's result as nullable where it can return null; on Scala 2 (or as a first step), enable WartRemover's `Null` wart (`wartremoverErrors += Wart.Null`) or Scalafix's `DisableSyntax.noNulls = true` so the code holds absence in `Option`. Then pay the assertions down rather than adding to them: each `.nn` is a null the compiler could not rule out — wrap the Java value in `Option(…)` at the boundary, pattern-match on `null` once there, or change the API so the null cannot arrive; an `unsafeNulls` import switches the checking off for everything after it.
Reference — by lens
| Lens | Score | Rating | Impact |
|---|---|---|---|
| Code Health | 61% | Adequate — gated by X5 | Capped at Fair by a Critical contributor — resolve it before relying on this lens. |
| Architecture | 90% | Adequate — gated by D26 | Capped at Fair by a Critical contributor — resolve it before relying on this lens. |
| Maturity | 52% | Adequate — gated by M2 | Capped at Fair by a Critical contributor — resolve it before relying on this lens. |
| Readiness | 76% | Adequate — gated by D13 | Capped at Fair by a Critical contributor — resolve it before relying on this lens. |
| Security | 62% | Adequate — gated by D29, D36 | Capped at Fair by a Critical contributor — resolve it before relying on this lens. |
| Performance | 81% | Strong | Strongest area. |
Not evidenced — 1 control(s) we could not find positive evidence for
- P5 DR & Backup — not evidenced — repo shows no backup/RTO/RPO controls; absence of evidence is not evidence of a working control
Not included — 54 check(s) not relevant to this codebase
- AC1 Text alternatives — No web markup found — accessibility is not applicable to this repository.
- AC2 Forms & labels — No web markup found — accessibility is not applicable to this repository.
- AC3 Page structure — No web markup found — accessibility is not applicable to this repository.
- AC4 Keyboard semantics — No web markup found — accessibility is not applicable to this repository.
- AC5 ARIA correctness — No web markup found — accessibility is not applicable to this repository.
- AC6 Visual & motion safety — No web markup found — accessibility is not applicable to this repository.
- AC7 A11y enforcement — No web markup found — accessibility is not applicable to this repository.
- AX1 Captive dependencies — Not applicable: this repository's Scala imports no dependency-injection container and defines no container of its own — nothing that both registers and resolves bindings, and nothing that names two lifetimes — so nothing holds one lifetime's instance while handing out another's.
- AX2 Stateful singletons — No container singleton was found, so there is no shared instance for concurrent requests to race on. No class in this Scala code is a Play controller, a Cask routes object, a Scalatra servlet, a Finatra controller, an Akka/Pekko HTTP routes holder or a JSR-330/Spring singleton, so no instance is shared between request threads.
- AX5 Architecture & structure — not assessed — architecture style/structure is computed from a project graph (projects, types, module namespaces) that was not loaded for this repository, because the repository is written in a language this check does not yet model, or because its projects failed to load. This is a gap in the analyzer, not a finding about this repository
- AX7 Slice cohesion — not applicable — not a vertical-slice architecture
- AX9 CQS / query purity — no CQRS query handlers detected — query purity is not applicable to this codebase
- AXB1 Runtime evidence locked — no reproducible boot — This repository has nothing the runtime tiers could boot or serve — no markup, no UI framework or web-server dependency, no UI component source, no native UI project and no API definition — nothing here is a surface to boot — so runtime a11y/egress/header evidence has no subject here. Not applicable: this is neither a gap in the scan nor a finding about your code.
- C1 Data Protection — Not assessed: these personal data controls are read from a source model (declarative annotations, request middleware, entity/column names, guard methods) that was not loaded for this repository — because the repository is written in a language this check does not yet model, or because its projects failed to load. Absence of an idiom this check recognises is NOT evidence that this repository lacks personal data controls: it may implement them entirely in its own ecosystem. This is a gap in the analyzer's language coverage, not a finding about this repository.
- C2 Access Controls — Not assessed: these authorization controls are read from a source model (declarative annotations, request middleware, entity/column names, guard methods) that was not loaded for this repository — because the repository is written in a language this check does not yet model, or because its projects failed to load. Absence of an idiom this check recognises is NOT evidence that this repository lacks authorization controls: it may implement them entirely in its own ecosystem. This is a gap in the analyzer's language coverage, not a finding about this repository.
- C3 Audit Trail — No personal data detected in a persisted data model — no PII-named column (email, first_name, date_of_birth, phone_number, …) or stored credential on a Slick table or in a SQL migration's CREATE TABLE or ALTER TABLE — and no database client (Slick, Doobie, Quill, ScalikeJDBC, Anorm, Skunk, a MongoDB or Cassandra driver, JDBC) imported either, so this repository keeps no sensitive data whose changes an audit trail would record. If it does (through a store configured outside this repository, for instance), the trail belongs to wherever that data is stored.
- C4 Data Retention — No personal data detected in a persisted data model — no PII-named field (email, firstName, dateOfBirth, phoneNumber, …) or stored credential on a Slick table or in a SQL migration's CREATE TABLE or ALTER TABLE — and no database or data-store client (Slick, Doobie, Quill, ScalikeJDBC, Anorm, Skunk, JDBC, MongoDB, Cassandra, …) imported either, so this repository keeps no personal data whose lifetime a retention limit would bound.
- C5 Data-Subject Rights — No personal data detected in a persisted data model — no PII-named field (email, firstName, dateOfBirth, phoneNumber, …) or stored credential on a Slick table or in a SQL migration's CREATE TABLE or ALTER TABLE — and no database or data-store client (Slick, Doobie, Quill, ScalikeJDBC, Anorm, Skunk, JDBC, MongoDB, Cassandra, …) imported either, so this repository keeps no personal data for a data subject to erase, export or consent over.
- D10 Test Quality — ~6647 lines of test source are present (.scala) but no test cases reached the test census for this repository — no test root we could resolve declared them, or the files we read declare no cases in a test framework we recognise — so skipped/assertion-free tests couldn't be counted. Not scored — this is a gap in the analyzer, not a finding about this repository.
- D11 Test Reliability — Test reliability not included — the .scala suite was found but not re-run
- D18 Solution Shape — D18 scores the shape of a .NET solution; this repository has no .NET solution or project files, so the dimension does not apply.
- D22 Internal API Consistency — The exposed public-API surface could not be collected — no C#/VB projects loaded.
- D23 Boundary Type-Coupling — No bounded-context organisation was detected either — neither a context-shaped layout nor 2+ sibling source directories each declaring an aggregate root. Declaring this codebase's bounded contexts (≥2) would let cross-boundary type coupling be assessed. Declare them in `.codehealth/config.yaml` at the repository root (create it if absent), mapping each context name to the module-path or namespace prefixes that belong to it — e.g. `architecture:` → `contexts:` → `Billing: ["src/billing", "Acme.Billing"]`, `Catalog: ["src/catalog", "Acme.Catalog"]`.
- D24 Comment Value — No inline comments to assess — comment value is not applicable here.
- D25 ADR Conformance — no ADRs to check
- D27 Navigability — D27 counts a call into the standard library or a dependency as unresolved for this repository's language (.scala), so too few call sites counted as resolved to assess navigability. Not scored: this is a gap in the analyzer, not a verdict about this repository.
- D31 IaC & Container Security — No Infrastructure-as-Code or container manifests found (Dockerfile, Docker Compose, Terraform, Kubernetes/Helm, CloudFormation, ARM, Bicep, Ansible); nothing to scan.
- D32 Data Compliance (PII/GDPR) — No personal data was found crossing a boundary the PII/GDPR ruleset checks — nothing written to a log or console sink, placed in a URL or query string, or persisted to browser storage. That is a clean result for the LEAK surface only: this ruleset detects personal data escaping, it does not inventory the personal data a repository holds, so it is not evidence that this repository has no personal-data surface. The personal-data map (Appendix C) and the C1-C5 compliance cards are what speak to that.
- D34 Knowledge Freshness — knowledge concentrated in recent work — freshness signal contradicted by repo activity
- D37 Vulnerability-disclosure Policy — No vulnerability-disclosure policy file found (SECURITY.md/.markdown/.rst/.txt at root or under .github/.forgejo/.gitea/docs, .well-known/security.txt). A coordinated-disclosure policy may live off-repo, so this is not evidenced rather than failed.
- D39 IL Efficiency — D39 measures the IL emitted by a .NET build; this repository has no .NET solution or project files, so the dimension does not apply.
- D40 Network Egress Confinement — No Kubernetes/orchestration workloads found in the repository manifests; network egress policy is a cluster-native control that may live at the platform/firewall layer, so there is nothing to assess here.
- D41 Kernel & Syscall Confinement — No Kubernetes/orchestration workloads found in the repository manifests; seccomp/AppArmor/SELinux confinement is a workload-level control, so there is nothing to assess here.
- D42 Runtime Threat Enforcement — No Kubernetes/orchestration workloads found in the repository manifests; runtime threat-detection and admission-control policy are cluster-level controls, so there is nothing to assess here.
- D44 Platform End-of-Life — Platform end-of-life not assessed — this repository declares no platform this pass reads
- D7 Architectural Integrity — no checkable ADRs, and no project-reference graph for the cycle pass to read — so this dimension makes no claim about dependency cycles in either direction (where this repository's language has an import-cycle lens, cycles are reported there). Architectural integrity not assessed
- D8 Code Coverage — Coverage not included — suite not readable by the collector
- DM1 Domain Modelling — applicable but not scored (2 signals for this style, 2 needed — the count is met but a required primary signal is absent): 168 value object(s); 6 domain event(s); its domain events are published by services or handlers — no domain entity raises one
- ED1 Event-Driven — not scored — this repository shows none of the 3 signals this lens looks for
- ED5 Idempotency — no mutating command handlers or message consumers detected — idempotency check not applicable
- ES1 Event Sourcing — not scored — this repository shows none of the 3 signals this lens looks for
- P12 CI test-gate honesty — Reported, not scored — and nothing was matched here. The coverage check applies to any stack, and the automatic-re-run check to any GitHub-Actions workflow, but the checks for excluded tests, skipped tests and sleep-based synchronisation currently recognise only some ecosystems' test-runner idioms, so on a repository built with another stack the zeros below mean 'not checked', not 'clean'.
- P2 Observability — This repository's JVM, JavaScript/TypeScript source (2 module(s), 81 file(s) read) declares no entry point and bootstraps no server, and nothing here deploys a service — it is a library, run inside whatever hosts it, so production observability (structured logging, tracing/metrics, health checks) is N/A. If it grows a binary or a service, the dimension reactivates.
- P7 Outbound HTTP resilience — not applicable — no HTTP server, API framework or worker entry point was found in the JVM, JavaScript/TypeScript source, so there is no service whose uptime a failing dependency could take down
- P8 Schema migrations — no ORM, schema-migration tool or schema auto-create was found in this repository's dependency manifests or source, so there is no database schema for this check to judge
- P9 Domain vs controller coverage — no coverage report found on disk — produce a coverage report in a standard format (`addSbtPlugin("org.scoverage" % "sbt-scoverage" % "<version>")` in `project/plugins.sbt`, then `sbt clean coverage test coverageReport`) and commit it — a hosted scan measures a clone of the repository, so a report that exists only in a working tree, a CI runner's or your own, never reaches it; the artefact is commonly gitignored, so `git add -f` that one file (or un-ignore its path) and commit it alongside the code it measures, or wire coverage collection into CI, to enable this cross-layer check
- S1 Web-Security Posture — No web surface: 75 Scala file(s) were read for weak hashes and ciphers, key material fixed in the source, disabled TLS certificate validation and obsolete TLS versions, and none was found. This repository serves no HTTP of its own — no HTTP-server artifact (akka-http, pekko-http, http4s, Play, Finagle, zio-http, cask, Scalatra, a tapir server, Jetty, Undertow, …) outside test scope in its build, and no server package imported or server bound in its production source — so HTTPS enforcement, HSTS, cookie flags and input validation are N/A here, as they are for a C# library or worker. If this codebase starts serving HTTP, the dimension reactivates automatically.
- X10 Duplicated predicate — Advisory — this card reports evidence and never carries a score, so there is nothing missing here.
- X2 Cancellation propagation — no C# was loaded; this repository's Scala was read, and no request in it can be cancelled by a caller — a Scala request takes no token: a Future cannot be cancelled, and cats-effect, ZIO and Monix interrupt the fiber that made the request from outside the call, not through a parameter
- X32 Type resolved by simple name across every loaded assembly — This check is about how a .NET program searches the assemblies loaded into its process for a type, and this repository contains no .NET source, so there is nothing here for it to assess. Not a gap in the analyzer and not a finding about your code.
- X4 Structured logging — This check asks whether log calls keep a message's values apart from its text, which needs a logger that can carry them as fields. This repository's Scala was read, and it logs through none that an interpolated message defeats: scala-logging takes an `s"…"` message apart into SLF4J's pattern and arguments at compile time, and log4s, grizzled-slf4j, Play's Logger, Akka's LoggingAdapter, sbt's Logger and Spark's Logging take one finished message (as log4net does in C#). Calls made straight through SLF4J (`org.slf4j.Logger`) would be judged.
- X6 Hand-rolled structured-format parsing — Advisory — this card reports evidence and never carries a score, so there is nothing missing here.
- X7 Silent fallback defaults — Advisory — this card reports evidence and never carries a score, so there is nothing missing here.
- X9 Subsumed condition operand — Advisory — this card reports evidence and never carries a score, so there is nothing missing here.
Appendix A — Findings (grouped)
Critical — 70 finding(s)
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
- REDACTED
Serious — 37 finding(s)
- FileTooLong: admin/AdminClient.scala zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala
- FileTooLong: internal/Runloop.scala zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala
- Runloop.handlePoll (cyclomatic 34) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:230
- Runloop.handleCommand (cyclomatic 25) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:452
- RebalanceCoordinator.doAwaitStreamCommits (cyclomatic 24) zio-kafka/src/main/scala/zio/kafka/consumer/internal/RebalanceCoordinator.scala:53
- PartitionStreamControl.newPartitionStream (cyclomatic 18) zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala:130
- ProducerLive.produceChunkAsyncWithFailures (cyclomatic 16) zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala:420
- SslHelper.doValidateEndpoint (cyclomatic 16) zio-kafka/src/main/scala/zio/kafka/utils/SslHelper.scala:41
- Runloop.handlePoll (cognitive 304) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:230
- Runloop.make (cognitive 105) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:725
- PartitionStreamControl.newPartitionStream (cognitive 93) zio-kafka/src/main/scala/zio/kafka/consumer/internal/PartitionStreamControl.scala:130
- RebalanceCoordinator.doAwaitStreamCommits (cognitive 61) zio-kafka/src/main/scala/zio/kafka/consumer/internal/RebalanceCoordinator.scala:53
- ProducerLive.produceChunkAsyncWithFailures (cognitive 49) zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala:420
- TransactionalProducer.make (cognitive 45) zio-kafka/src/main/scala/zio/kafka/producer/TransactionalProducer.scala:91
- ZioMetricsConsumerMetricsObserver.observeRunloopMetrics (cognitive 43) zio-kafka/src/main/scala/zio/kafka/consumer/metrics/ZioMetricsConsumerMetricsObserver.scala:164
- Runloop.handleCommand (cognitive 38) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:452
- Runloop.run (cognitive 38) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:594
- Runloop.observeRunloopMetrics (cognitive 28) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:656
- ProducerLive.produceAsync (cognitive 25) zio-kafka/src/main/scala/zio/kafka/producer/Producer.scala:331
- SslHelper.doValidateEndpoint (cognitive 25) zio-kafka/src/main/scala/zio/kafka/utils/SslHelper.scala:41
- RebalanceCoordinator.toRebalanceListener (cognitive 24) zio-kafka/src/main/scala/zio/kafka/consumer/internal/RebalanceCoordinator.scala:186
- ZioKafkaConsumerBenchmark.initialize (cognitive 21) zio-kafka-bench/src/main/scala/zio/kafka/bench/ZioKafkaConsumerBenchmark.scala:23
- LiveCommitter.commit (cognitive 21) zio-kafka/src/main/scala/zio/kafka/consumer/internal/LiveCommitter.scala:34
- LiveCommitter.processQueuedCommits (cognitive 19) zio-kafka/src/main/scala/zio/kafka/consumer/internal/LiveCommitter.scala:51
- LiveCommitter.handleCommitCompletion (cognitive 17) zio-kafka/src/main/scala/zio/kafka/consumer/internal/LiveCommitter.scala:89
- Runloop.offerRecordsToStreams (cognitive 17) zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala:131
- Change coupling: Offset.scala ↔ Runloop.scala zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala:1
- REDACTED
- REDACTED
- REDACTED
- Duplicated block (18–19 lines × 2) zio-kafka-testkit/src/main/scala/zio/kafka/testkit/Kafka.scala:52
- Duplicated block (10–11 lines × 2) zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala:673
- Duplicated block (10 lines × 2) zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala:560
- Duplicated block (7 lines × 2) zio-kafka-bench/src/main/scala/zio/kafka/bench/ZioKafkaProducerBenchmark.scala:26
- Off the main sequence: zioKafka
- Sync-over-async blocking zio-kafka/src/main/scala/zio/kafka/consumer/internal/package.scala:36
- Swallowed exception (caught, then discarded) zio-kafka/src/main/scala/zio/kafka/utils/SslHelper.scala:54
Minor — 17 finding(s)
- README/code drift README.md:1
- README/code drift README.md:1
- README/code drift README.md:75
- README/code drift README.md:173
- README/code drift docs/tutorial.md:49
- Fat interface: AdminClient (37 abstract members) zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala:82
- Fat interface: Consumer (20 abstract members) zio-kafka/src/main/scala/zio/kafka/consumer/Consumer.scala:22
- Documentation: no installation or build instructions docs/index.md
- Documentation: no project overview docs/writing-tests.md
- Off-boarding risk: anonymized user #1
- No ADRs found
- Projects may be oversized for their cohesion
- REDACTED
- REDACTED
- No ADRs
- Benchmarks don't track allocations zio-kafka-bench/src/main/scala/zio/kafka/bench/ZioKafkaSeqProducerBenchmark.scala
- Scala's null is not held to the type system everywhere
Minor — 1 finding(s)
- Outdated: org.apache.kafka:kafka-clients
Appendix B — Reproduction & audit trail
| Dimension | Tool | Version | Command | Findings | Raw output |
|---|---|---|---|---|---|
| D28 · Secrets (history) | gitleaks | — | gitleaks detect --no-banner --config /opt/gitleaks-rules/watchdog-gitleaks.toml --report-format json --report-path /tmp/watchdog-gitleaks-08f87e75e41f4f4cb3d794c712bcb2ca/history.json --exit-code 0 --source . | 0 | artifacts/raw/gitleaks-history.json |
| D28 · Secrets (history) | gitleaks | — | gitleaks detect --no-git --no-banner --config /opt/gitleaks-rules/watchdog-gitleaks.toml --report-format json --report-path /tmp/watchdog-gitleaks-08f87e75e41f4f4cb3d794c712bcb2ca/tree.json --exit-code 0 --source . | 1 | artifacts/raw/gitleaks-tree.json |
| D29 · Static Analysis (SAST) | semgrep | — | semgrep --config /opt/semgrep-rules/security-audit.yml --config /opt/semgrep-rules/owasp-top-ten.yml --config /opt/semgrep-rules/watchdog-sast.yml --json --quiet --timeout 10 --timeout-threshold 3 --metrics off . | 66 | artifacts/raw/semgrep.json |
| D30 · Dependency Vulnerabilities | trivy | — | trivy fs --scanners vuln --format json --quiet --severity CRITICAL,HIGH,MEDIUM,LOW --skip-dirs **/bin/** --skip-dirs **/obj/** . --skip-db-update | 0 | artifacts/raw/trivy-fs.json |
| D31 · IaC & Container Security | trivy | — | trivy: not applicable — No Infrastructure-as-Code or container manifests found (Dockerfile, Docker Compose, Terraform, Kubernetes/Helm, CloudFormation, ARM, Bicep, Ansible); nothing to scan. | 0 | — |
| D32 · Data Compliance (PII/GDPR) | semgrep | — | semgrep: not applicable — No personal data was found crossing a boundary the PII/GDPR ruleset checks — nothing written to a log or console sink, placed in a URL or query string, or persisted to browser storage. That is a clean result for the LEAK surface only: this ruleset detects personal data escaping, it does not inventory the personal data a repository holds, so it is not evidence that this repository has no personal-data surface. The personal-data map (Appendix C) and the C1-C5 compliance cards are what speak to that. | 0 | — |
| D37 · Vulnerability-disclosure Policy | disclosure | — | disclosure: not applicable — No vulnerability-disclosure policy file found (SECURITY.md/.markdown/.rst/.txt at root or under .github/.forgejo/.gitea/docs, .well-known/security.txt). A coordinated-disclosure policy may live off-repo, so this is not evidenced rather than failed. | 0 | — |
| D40 · Network Egress Confinement | runtime-hardening | — | runtime-hardening: not applicable — No Kubernetes/orchestration workloads found in the repository manifests; network egress policy is a cluster-native control that may live at the platform/firewall layer, so there is nothing to assess here. | 0 | — |
| D41 · Kernel & Syscall Confinement | runtime-hardening | — | runtime-hardening: not applicable — No Kubernetes/orchestration workloads found in the repository manifests; seccomp/AppArmor/SELinux confinement is a workload-level control, so there is nothing to assess here. | 0 | — |
| D42 · Runtime Threat Enforcement | runtime-hardening | — | runtime-hardening: not applicable — No Kubernetes/orchestration workloads found in the repository manifests; runtime threat-detection and admission-control policy are cluster-level controls, so there is nothing to assess here. | 0 | — |
| D43 · Malicious Dependencies | trivy | — | trivy fs --scanners vuln --format json --quiet --severity CRITICAL,HIGH,MEDIUM,LOW --skip-dirs **/bin/** --skip-dirs **/obj/** . --skip-db-update | 0 | artifacts/raw/trivy-fs.json |