Home / debezium / debezium
AI Slop Code Risk Monitor

debezium/debezium

SlopCodeMonitor badge for debezium/debezium Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.

1.9 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for debezium/debezium, a Java project with 13,291 GitHub stars. SynthScan examined 618,860 lines of code across 4182 source files, recording 327 pattern matches distributed across 15 syntactic categories. The legacy adjusted pattern signal is 1.9 (Low pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

1.9
Adjusted Signal
1.9
Raw Pattern Score
100%
Time Factor
2026-10-30
Last Push
13.3K
Stars
Java
Language
618.9K
Lines of Code
4.2K
Files
327
Pattern Hits
2026-10-31
Scan Date
0.02
HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 0.9/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 88 finding(s).

Hallucinated Dependency & Supply Chain Risk 7.1/100 · LOW

Are imports declared and package/API names verified? 188 finding(s).

Agent Over-Engineering Ratio 1.2/100 · LOW

Are wrappers, guards, and repeated structures necessary? 51 finding(s).

PR Review Velocity Impact 7.9/100 · LOW

Which changes need focused human review? 327 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 63HIGH 6MEDIUM 49LOW 209

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 327 distinct pattern matches across 15 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Hallucination Indicators63 hits · 775 pts
SeverityFileLineSnippetContext
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1276 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1281 r.deliver(io.debezium.data.geometry.Geometry.createValue(schema, geom.getWkb(), geom.getSrid()));CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1286 r.deliver(io.debezium.data.geometry.Geometry.createValue(schema, geom.getWkb(), geom.getSrid()));CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1290 r.deliver(io.debezium.data.geometry.Geometry.createValue(schema, geom.getWkb(), geom.getSrid()));CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1301 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geography.createValue(fieldDefn.schema(),CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1306 r.deliver(io.debezium.data.geometry.Geography.createValue(schema, geom.getWkb(), geom.getSrid()));CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1311 r.deliver(io.debezium.data.geometry.Geography.createValue(schema, geom.getWkb(), geom.getSrid()));CODE
CRITICAL⚡…ezium/connector/postgresql/PostgresValueConverter.java1315 r.deliver(io.debezium.data.geometry.Geography.createValue(schema, geom.getWkb(), geom.getSrid()));CODE
CRITICAL⚡…zium/connector/oracle/AbstractOracleDatatypesTest.java244 new SchemaAndValueField("VAL_DATE", org.apache.kafka.connect.data.Timestamp.builder().optional().build(),CODE
CRITICAL⚡…zium/connector/oracle/AbstractOracleDatatypesTest.java246 new SchemaAndValueField("VAL_TS", org.apache.kafka.connect.data.Timestamp.builder().optional().build(),CODE
CRITICAL⚡…zium/connector/oracle/AbstractOracleDatatypesTest.java248 new SchemaAndValueField("VAL_TS_PRECISION2", org.apache.kafka.connect.data.Timestamp.builder().optional().buCODE
CRITICAL⚡…zium/connector/oracle/AbstractOracleDatatypesTest.java250 new SchemaAndValueField("VAL_TS_PRECISION4", org.apache.kafka.connect.data.Timestamp.builder().optional().buCODE
CRITICAL⚡…zium/connector/oracle/AbstractOracleDatatypesTest.java252 new SchemaAndValueField("VAL_TS_PRECISION9", org.apache.kafka.connect.data.Timestamp.builder().optional().buCODE
CRITICAL⚡…zium/connector/oracle/AbstractOracleDatatypesTest.java260 new SchemaAndValueField("VAL_MAX_DATE", org.apache.kafka.connect.data.Timestamp.builder().optional().build()CODE
CRITICAL…um/connector/oracle/logminer/LogFileCollectorTest.java2363 org.junit.jupiter.api.Assertions.fail("Expected LogFileNotFoundException to be thrown");CODE
CRITICAL…um/connector/oracle/logminer/LogFileCollectorTest.java2387 org.junit.jupiter.api.Assertions.fail("Expected LogFileNotFoundException to be thrown");CODE
CRITICAL…um/connector/oracle/logminer/LogFileCollectorTest.java2412 org.junit.jupiter.api.Assertions.fail("Expected LogFileNotFoundException to be thrown");CODE
CRITICAL…um/connector/oracle/logminer/LogFileCollectorTest.java2440 org.junit.jupiter.api.Assertions.fail("Expected LogFileNotFoundException to be thrown");CODE
CRITICAL…bezium/connector/sqlserver/SqlServerMaxColumnTest.java147 final var fieldDefn = new org.apache.kafka.connect.data.Field(CODE
CRITICAL…bezium/connector/sqlserver/SqlServerMaxColumnTest.java180 final var fieldDefn = new org.apache.kafka.connect.data.Field(CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java157 new SchemaAndValueField("val_date", org.apache.kafka.connect.data.Date.builder().optional().build(),CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java161 new SchemaAndValueField("val_time_p2", org.apache.kafka.connect.data.Time.builder().optional().build(),CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java165 new SchemaAndValueField("val_time", org.apache.kafka.connect.data.Time.builder().optional().build(),CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java169 new SchemaAndValueField("val_time_p7", org.apache.kafka.connect.data.Time.builder().optional().build(),CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java173 new SchemaAndValueField("val_datetime2", org.apache.kafka.connect.data.Timestamp.builder().optional().build(CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java178 new SchemaAndValueField("val_datetime", org.apache.kafka.connect.data.Timestamp.builder().optional().build()CODE
CRITICAL⚡…onnector/sqlserver/AbstractSqlServerDatatypesTest.java182 new SchemaAndValueField("val_smalldatetime", org.apache.kafka.connect.data.Timestamp.builder().optional().buCODE
CRITICAL…/io/debezium/connector/mongodb/MongoDbConnectorIT.java2758 Bson filter = com.mongodb.client.model.Filters.eq("name", "Jon Snow");CODE
CRITICAL…/io/debezium/connector/mongodb/MongoDbConnectorIT.java2826 Bson filter = com.mongodb.client.model.Filters.eq("name", "Jon Snow");CODE
CRITICAL…/connector/mongodb/sink/SinkConnectorReplicaSetIT.java37 TestInfrastructureHelper.setupDebeziumContainer(io.debezium.connector.mongodb.Module.version(), TestInfrastructuCODE
CRITICAL…nector/mongodb/sink/SinkConnectorShardedClusterIT.java39 TestInfrastructureHelper.setupDebeziumContainer(io.debezium.connector.mongodb.Module.version(), TestInfrastructuCODE
CRITICAL…onnector/mongodb/metadata/MongoDbMetadataProvider.java32 componentMetadataFactory.createComponentMetadata(new MongoDbSinkConnector(), io.debezium.connector.mongoCODE
CRITICAL…/io/debezium/transforms/ExtractNewRecordStateTest.java1018 org.apache.kafka.connect.errors.ConnectException e = org.junit.jupiter.api.Assertions.assertThrows(CODE
CRITICAL…java/io/debezium/transforms/TimezoneConverterTest.java60 .field("order_date_kc_timestamp", org.apache.kafka.connect.data.Timestamp.builder().optional().build())CODE
CRITICAL⚡…ctor/jdbc/type/TimestampClampOutOfRangeValuesTest.java150 final var db2Type = new io.debezium.connector.jdbc.dialect.db2.ZonedTimestampType();CODE
CRITICAL⚡…ctor/jdbc/type/TimestampClampOutOfRangeValuesTest.java155 final var db2iType = new io.debezium.connector.jdbc.dialect.db2i.ZonedTimestampType();CODE
CRITICAL⚡…ctor/jdbc/type/TimestampClampOutOfRangeValuesTest.java160 final var oracleType = new io.debezium.connector.jdbc.dialect.oracle.ZonedTimestampType();CODE
CRITICAL⚡…dbc/type/debezium/StructuredTemporalPrecisionTest.java33 final var type = new io.debezium.connector.jdbc.type.connect.ConnectTimestampType();CODE
CRITICAL⚡…dbc/type/debezium/StructuredTemporalPrecisionTest.java35 final var schema = org.apache.kafka.connect.data.Timestamp.builder()CODE
CRITICAL⚡…dbc/type/debezium/StructuredTemporalPrecisionTest.java45 final var type = new io.debezium.connector.jdbc.type.connect.ConnectTimeType();CODE
CRITICAL⚡…dbc/type/debezium/StructuredTemporalPrecisionTest.java47 final var schema = org.apache.kafka.connect.data.Time.builder()CODE
CRITICAL…connector/jdbc/transforms/FieldNameTransformation.java242 builder = org.apache.kafka.connect.transforms.util.SchemaUtil.copySchemaBasics(CODE
CRITICAL…rage/kafka/KafkaConnectOffsetStorageWriterAdapter.java35 this.delegate = new org.apache.kafka.connect.storage.OffsetStorageWriter(offsetStore.getDelegate(), namespace, kCODE
CRITICAL…ommon/src/test/java/io/debezium/util/InternerTest.java250 org.junit.jupiter.api.Assertions.assertThrows(CODE
CRITICAL…a/io/debezium/connector/common/BaseSourceTaskTest.java210 org.apache.kafka.connect.util.LoggingContext.clear();CODE
CRITICAL…a/io/debezium/connector/common/BaseSourceTaskTest.java220 try (var kafkaLoggingContext = org.apache.kafka.connect.util.LoggingContext.forTask(connectorTaskId)) {CODE
CRITICAL…ommon/src/test/java/io/debezium/data/VerifyRecord.java86 avroKeyConverter = new io.apicurio.registry.utils.converter.AvroConverter();CODE
CRITICAL…ommon/src/test/java/io/debezium/data/VerifyRecord.java87 avroValueConverter = new io.apicurio.registry.utils.converter.AvroConverter();CODE
CRITICAL…/main/java/io/debezium/jdbc/TemporalPrecisionMode.java60 x -> org.apache.kafka.connect.data.Time.builder(),CODE
CRITICAL…/main/java/io/debezium/jdbc/TemporalPrecisionMode.java61 x -> org.apache.kafka.connect.data.Timestamp.builder()),CODE
CRITICAL…rc/main/java/io/debezium/connector/SnapshotRecord.java48 && io.debezium.data.Enum.LOGICAL_NAME.equals(source.schema().field(AbstractSourceInfo.SNAPSHOT_KEY).scheCODE
CRITICAL…-common/src/main/java/io/debezium/data/SchemaUtil.java324 SchemaBuilder builder = org.apache.kafka.connect.transforms.util.SchemaUtil.copySchemaBasics(source);CODE
CRITICAL…src/main/java/io/debezium/serde/ConnectValueSerde.java534 if (org.apache.kafka.connect.data.Date.LOGICAL_NAME.equals(schemaName)CODE
CRITICAL…/io/debezium/connector/mysql/MySqlConnectorConfig.java299 .withDefault(com.mysql.cj.jdbc.Driver.class.getName())CODE
CRITICAL…sql/antlr/listener/ColumnDefinitionParserListener.java288 dataType = io.debezium.relational.ddl.DataType.userDefinedType(contextText);CODE
CRITICAL…ava/io/debezium/connector/mysql/gtid/MySqlGtidSet.java47 new com.github.shyiko.mysql.binlog.GtidSet(gtids).getUUIDSets().forEach(uuidSet -> {CODE
CRITICAL…ain/java/io/debezium/connector/binlog/EventBuffer.java169 // Position for TABLE_MAP is not stored by com.github.shyiko.mysql.binlog.BinaryLogClient.updateClientBinlogFileCOMMENT
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java175 return io.debezium.data.geometry.Point.builder();CODE
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java184 return io.debezium.data.geometry.Geometry.builder();CODE
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java716 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), CODE
3 more matches not shown…
Decorative Section Separators43 hits · 123 pts
SeverityFileLineSnippetContext
MEDIUM…debezium/connector/postgresql/PostgresConnectorIT.java4626 // ── Scenario 1: INSERT — jsonb must be the real inserted value ─────COMMENT
MEDIUM…debezium/connector/postgresql/PostgresConnectorIT.java4636 // ── Scenario 2: UPDATE that does NOT touch the jsonb column ────────COMMENT
MEDIUM…debezium/connector/postgresql/PostgresConnectorIT.java4663 // ── Scenario 4: UPDATE that DOES change the jsonb column ──────────COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh13# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh15# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh23# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh25# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh237# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh239# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh244# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh246# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh372# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh374# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh382# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh384# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh394# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡jenkins-jobs/scripts/pre-release.sh396# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh60# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh62# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh115# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh117# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh135# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh137# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh156# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh158# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh207# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh209# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh220# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh222# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh261# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh263# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh310# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh312# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh324# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh326# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh345# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh347# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh359# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh361# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh427# ---------------------------------------------------------------------------COMMENT
MEDIUMjenkins-jobs/scripts/pre-release.sh429# ---------------------------------------------------------------------------COMMENT
MEDIUM.github/nightly-build-config.yml1# ========================================COMMENT
MEDIUM.github/nightly-build-config.yml3# ========================================COMMENT
Fake / Example Data91 hits · 90 pts
SeverityFileLineSnippetContext
LOW…va/io/debezium/connector/postgresql/OpenLineageIT.java558 assertThat(ownership).contains(entry("Mario", "maintainer"), entry("John Doe", "Data scientist"));CODE
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java6342 connection.execute("INSERT INTO dbz1676 values ('doe','john',21,'123 Main St', 'john@doe.com', sysdate, 1)")STRING
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java6396 connection.execute("INSERT INTO dbz1676 values ('doe','john',21,'123 Main St', 'john@doe.com', sysdate, 1, 'STRING
LOW…ava/io/debezium/connector/sqlserver/OpenLineageIT.java209 assertThat(ownership).contains(entry("Mario", "maintainer"), entry("John Doe", "Data scientist"));CODE
LOW…/debezium/connector/mongodb/JsonSerializationTest.java22 var composite = new BsonDocument("email", new BsonString("foo@bar.com"))CODE
LOW…/debezium/connector/mongodb/JsonSerializationTest.java34 var composite = new BsonDocument("email", new BsonString("foo@bar.com"))CODE
LOW…/java/io/debezium/connector/mongodb/OpenLineageIT.java270 assertThat(ownership).contains(entry("Mario", "maintainer"), entry("John Doe", "Data scientist"));CODE
LOW…/io/debezium/connector/mongodb/MongoDbConnectorIT.java3013 Document doc = new Document("_id", 4367438483L).append("name", "John Doe").append("age", 25);CODE
LOW…/io/debezium/connector/mongodb/MongoDbConnectorIT.java3024 Document doc1 = new Document("_id", 1).append("name", "Jane Doe").append("age", 22);CODE
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java872 .append("fullName", "John Doe")CODE
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java892 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");CODE
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java910 .append("fullName", "John Doe")CODE
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java920 assertThat(payload.get("fullName")).isEqualTo("John Doe");CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java102 .append("fullName", "John Doe")CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java125 assertThat(payload.get("fullName")).isEqualTo("John Doe");CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java141 .append("fullName", "John Doe")CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java167 assertThat(payload.get("fullName")).isEqualTo("John Doe");CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java181 .append("fullName", "John Doe")CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java205 assertThat(payload.get("fullName")).isEqualTo("John Doe");CODE
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java224 .append("fullName", "John Doe")CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java215 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java260 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java303 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java346 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java389 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java434 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java477 customersBefore.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java512 ordersBefore.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java547 otherBefore.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java590 customersBefore.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java625 ordersBefore.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java1034 before.put("name", "John Doe");CODE
LOW…java/io/debezium/transforms/TimezoneConverterTest.java1082 before.put("name", "John Doe");CODE
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java988 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");CODE
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1072 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");CODE
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1114 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");CODE
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1177 assertThat(payloadStruct.get("fullName")).isEqualTo("John Doe");CODE
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1210 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java211 .after("name", "John Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java237 .after(columnNameTransformation.apply("name"), "John Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java347 .after("name", "John Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java367 .after("name", "John Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java382 .before("name", "John Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java384 .after("name", "Jane Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java423 .before("name", "John Doe")CODE
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java440 .before("name", "John Doe")CODE
LOW…dbc/integration/AbstractJdbcSinkDeleteEnabledTest.java61 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…dbc/integration/AbstractJdbcSinkDeleteEnabledTest.java364 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…dbc/integration/AbstractJdbcSinkDeleteEnabledTest.java392 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java67 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java98 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java129 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java157 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java164 .column("name").isText(false).hasValues("John Doe")CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java200 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java234 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java262 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java269 .column("name").isText(false).hasValues("John Doe")CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java303 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java339 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");CODE
31 more matches not shown…
Over-Commented Block61 hits · 60 pts
SeverityFileLineSnippetContext
LOW…a/io/debezium/connector/postgresql/PostgresSchema.java181 * Discard any currently-cached schemas and rebuild them using the filters.COMMENT
LOW…ctor/postgresql/PostgresSnapshotChangeEventSource.java101 // If using catch up streaming, the connector opens the transaction that the snapshot will eventually useCOMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java161 case BEGIN:COMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java401 columnNames.add(columnName);COMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java421 Table table = resolveRelationFromMetadata(new PgOutputRelationMetaData(relationId, schemaName, tableName, columnCOMMENT
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java561COMMENT
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java4841 // This bulk update also adjusts two rows, but this changes both a non-LOB and LOB column.COMMENT
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java4861 // Event 1 - Non-LOB column a=35 changed to a=14COMMENT
LOW…io/debezium/connector/oracle/OracleClobDataTypeIT.java1961 // any of the CLOB fields, we expect the placeholder.COMMENT
LOW…logminer/buffered/AbstractFindRolledBackRangeTest.java441 assertThat(logInterceptor.containsWarnMessage("Manual investigation is required")).isFalse();COMMENT
LOW…logminer/buffered/AbstractFindRolledBackRangeTest.java841 // INSERT INTO DBZ1960_26 (ID, LOB0) VALUES (1, 'LOB0-1-0');COMMENT
LOW…logminer/buffered/AbstractFindRolledBackRangeTest.java901 @TestCOMMENT
LOW…logminer/buffered/AbstractFindRolledBackRangeTest.java941 // UPDATE DBZ1960_29 SET STR0 = 'STR0-1-2' WHERE ID = 1;COMMENT
LOW…logminer/buffered/AbstractFindRolledBackRangeTest.java961 assertThat(logInterceptor.containsWarnMessage("Manual investigation is required")).isFalse();COMMENT
LOW…logminer/buffered/AbstractFindRolledBackRangeTest.java1001 public void testUpdateXmlWithoutInternalAndRollbackUpdateInlineAndXml() throws Exception {COMMENT
LOW…/main/java/io/debezium/connector/oracle/CommitScn.java361COMMENT
LOW…gminer/AbstractLogMinerStreamingChangeEventSource.java381 LOGGER.debug("The previous batch's unavailable log problem has been cleared.");COMMENT
LOW…va/io/debezium/connector/oracle/logminer/SqlUtils.java21 * todo When you use the SKIP_CORRUPTION option to DBMS_LOGMNR.START_LOGMNR, any corruptions in the redo log files aCOMMENT
LOW…va/io/debezium/connector/oracle/logminer/SqlUtils.java141 // combined with a list of redo logs that should be mined.COMMENT
LOW…va/io/debezium/connector/oracle/logminer/SqlUtils.java161 // SELECT A.NAME AS FILE_NAME, A.FIRST_CHANGE# FIRST_CHANGE, A.NEXT_CHANGE# NEXT_CHANGE, 'YES',COMMENT
LOW…ogminer/buffered/AbstractLogMinerTransactionCache.java81 // Returning the eldest transaction would be misleading here because each cache implementation may notCOMMENT
LOW…le/logminer/buffered/BufferedLogMinerQueryBuilder.java121 // generated to capture the following operations as a baseline:COMMENT
LOW…nnector/oracle/xstream/XStreamChangeRecordEmitter.java41 // For LOB_WRITE/LOB_TRIM/LOB_ERASE, Oracle XStream typically carries only the LOBCOMMENT
LOW…debezium/connector/oracle/xstream/LcrEventHandler.java241 chunkValues = new HashMap<>(0);COMMENT
LOWdebezium-quarkus-outbox-reactive/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarkuCOMMENT
LOWquarkus-debezium-parent/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarkuCOMMENT
LOW…ezium/connector/mongodb/ShardedMongoDbConnectorIT.java81COMMENT
LOW…ium/connector/mongodb/ChangeStreamPipelineFactory.java241 includedSignalCollectionFilters);COMMENT
LOW…bezium/connector/jdbc/JdbcSinkConnectorConfigTest.java361 // }COMMENT
LOW…ium/connector/jdbc/e2e/AbstractJdbcSinkPipelineIT.java621 // based on the supplied scale. For example, a scale of -1 rounds to a factor of 10 while scaleCOMMENT
LOW…ium/connector/jdbc/e2e/AbstractJdbcSinkPipelineIT.java2801 //COMMENT
LOW…ium/connector/jdbc/type/connect/ConnectStringType.java41 // this case we should ignore it.COMMENT
LOW…ebezium/connector/jdbc/dialect/db2i/ZonedTimeType.java41 // NOTE:COMMENT
LOW…debezium/connector/jdbc/dialect/db2/ZonedTimeType.java41 // NOTE:COMMENT
LOWjenkins-jobs/scripts/pre-release.sh1#!/bin/bashCOMMENT
LOWjenkins-jobs/scripts/pre-release.sh61# Derive PREVIOUS_VERSIONCOMMENT
LOWjenkins-jobs/scripts/pre-release.sh81COMMENT
LOW.github/nightly-build-config.yml1# ========================================COMMENT
LOW.github/config/zulip-user-mapping.txt1# GitHub handle to Zulip user ID mappingCOMMENT
LOW.github/workflows/debezium-workflow-pr.yml321 echo "No previous dependency delta found for this pull request"COMMENT
LOW.github/workflows/debezium-workflow-push.yml61 - id: maven-cache-checkCOMMENT
LOW…cripts/release-container-images/build-tagged-images.sh1#!/bin/bashCOMMENT
LOW…ce/snapshot/incremental/AbstractChunkQueryBuilder.java121 //COMMENT
LOW…/src/test/resources/mariadb/examples/fast/ddl_drop.sql81#endCOMMENT
LOW…rser/src/test/resources/mysql/examples/expressions.sql1#beginCOMMENT
LOW…arser/src/test/resources/mysql/examples/dml_select.sql121#endCOMMENT
LOW…arser/src/test/resources/mysql/examples/dml_select.sql221-- Index hints: https://dev.mysql.com/doc/refman/5.7/en/index-hints.htmlCOMMENT
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql341SET i = i + 1;COMMENT
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql561# IF @merchantId > 0 THENCOMMENT
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql581# WHERE tax_vat.default = 1COMMENT
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql601# SELECT tax_vat.tax_vat_idCOMMENT
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql761#beginCOMMENT
LOW…src/test/resources/mysql/examples/legacy/dml_table.sql1###https://dev.mysql.com/doc/refman/8.0/en/table.htmlCOMMENT
LOWdebezium-quarkus-outbox-common/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarkuCOMMENT
LOW…a/io/debezium/connector/binlog/BinlogRegressionIT.java221 //COMMENT
LOW…a/io/debezium/connector/binlog/BinlogRegressionIT.java561 // '0000-00-00 00:00:00.000');COMMENT
LOW…a/io/debezium/connector/binlog/BinlogReadBinLogIT.java321 if (sql.equalsIgnoreCase("BEGIN") || sql.equalsIgnoreCase("COMMIT")) {COMMENT
LOW…va/io/debezium/connector/binlog/BinlogConnectorIT.java881 // Start the connector ...COMMENT
LOW…/connector/binlog/BinlogSnapshotChangeEventSource.java141 // which is why we explicitly set it here.COMMENT
LOW…ctor/binlog/history/BinlogHistoryRecordComparator.java101 // would be reading a binlog of a server that no longer has GTIDs. If they are enabled, disabled,COMMENT
1 more matches not shown…
Unused Imports32 hits · 32 pts
SeverityFileLineSnippetContext
LOWdebezium-e2e-benchmark/py/time1-tpcplot-full.py4CODE
LOWdebezium-e2e-benchmark/py/time1-tpcplot-full.py5CODE
LOWdebezium-e2e-benchmark/py/time1-tpcplot-full.py8CODE
LOWdebezium-e2e-benchmark/py/tpcplot.py5CODE
LOWdebezium-e2e-benchmark/py/tpcplot.py6CODE
LOWdebezium-e2e-benchmark/py/tpcplot.py9CODE
LOWdebezium-e2e-benchmark/py/time1-tpcplot-detail.py4CODE
LOWdebezium-e2e-benchmark/py/time1-tpcplot-detail.py5CODE
LOWdebezium-e2e-benchmark/py/time1-tpcplot-detail.py8CODE
LOWdebezium-e2e-benchmark/py/time-delta-hist.py4CODE
LOWdebezium-e2e-benchmark/py/time-delta-hist.py5CODE
LOWdebezium-e2e-benchmark/py/time-delta-hist.py8CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py6CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py10CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py11CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py12CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py14CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py15CODE
LOWdebezium-e2e-benchmark/py/tpc-run-test.py16CODE
LOWdebezium-e2e-benchmark/py/runplots.py3CODE
LOWdebezium-e2e-benchmark/py/runplots.py4CODE
LOWdebezium-e2e-benchmark/py/runplots.py6CODE
LOWdebezium-e2e-benchmark/py/runplots.py7CODE
LOWdebezium-e2e-benchmark/py/runplots.py8CODE
LOWdebezium-e2e-benchmark/py/runplots.py9CODE
LOWdebezium-e2e-benchmark/py/runplots.py10CODE
LOWdebezium-e2e-benchmark/py/runplots.py11CODE
LOWdebezium-e2e-benchmark/py/runplots.py12CODE
LOWdebezium-e2e-benchmark/py/runplots.py13CODE
LOWdebezium-e2e-benchmark/py/runplots.py14CODE
LOWdebezium-e2e-benchmark/py/runplots.py16CODE
LOWdebezium-e2e-benchmark/py/runplots.py17CODE
Verbosity Indicators8 hits · 18 pts
SeverityFileLineSnippetContext
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4320 // Step 1: Create table WITHOUT duplicate columnsCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4328 // Step 2: Insert initial dataCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4331 // Step 3: Start connector - should succeed (no duplicates yet)COMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4337 // Step 4: Wait for streaming to startCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4340 // Step 5: NOW ALTER TABLE to add duplicate column during streamingCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4344 // Step 6: Insert a record to trigger RELATION message processingCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4349 // Step 7: Wait for some time to allow RELATION message processingCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4352 // Step 8: Connector should fail due to Layer 2 validation in handleRelationMessage()COMMENT
Structural Annotation Overuse8 hits · 18 pts
SeverityFileLineSnippetContext
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4320 // Step 1: Create table WITHOUT duplicate columnsCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4328 // Step 2: Insert initial dataCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4331 // Step 3: Start connector - should succeed (no duplicates yet)COMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4337 // Step 4: Wait for streaming to startCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4340 // Step 5: NOW ALTER TABLE to add duplicate column during streamingCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4344 // Step 6: Insert a record to trigger RELATION message processingCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4349 // Step 7: Wait for some time to allow RELATION message processingCOMMENT
LOW⚡…zium/connector/postgresql/RecordsStreamProducerIT.java4352 // Step 8: Connector should fail due to Layer 2 validation in handleRelationMessage()COMMENT
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGH…rc/test/resources/mariadb/examples/fast/dml_select.sql0as col2; select '\'quoted string\' ' col1, 'backslash \\ ' ', two double quote "" ' ', two single quoteSTRING
HIGH…arser/src/test/resources/mysql/examples/dml_select.sql0as col2; select '\'quoted string\' ' col1, 'backslash \\ ' ', two double quote "" ' ', two single quoteSTRING
HIGH…rc/test/resources/mysql/examples/legacy/dml_select.sql0as col2; select '\'quoted string\' ' col1, 'backslash \\ ' ', two double quote "" ' ', two single quoteSTRING
Redundant / Tautological Comments7 hits · 10 pts
SeverityFileLineSnippetContext
LOWjenkins-jobs/scripts/check-contributors.sh31 # Check if the supplied contributor name from git history should be filteredCOMMENT
LOW.github/workflows/pr-notification.yml51 # Check if user is in mapping fileCOMMENT
LOW.github/workflows/first-time-contributor-prs.yml71 # Check if any workflow run for this commit is waiting for approvalCOMMENT
LOW.github/actions/check-artifact-size/action.yml85 # Check if this repository exceeds its specific thresholdCOMMENT
LOW.github/actions/check-artifact-size/action.yml209 # Check if exceeds warning threshold (Latest Version - triggers Zulip)COMMENT
LOW.github/actions/check-artifact-size/action.yml237 # Check if exceeds warning threshold (Final Version - report only, no Zulip)COMMENT
LOW.github/actions/check-artifact-size/action.yml262 # Check if any LATEST version warnings were recorded (triggers Zulip)COMMENT
Cross-Language Confusion (JS/TS)2 hits · 10 pts
SeverityFileLineSnippetContext
HIGH…-mongodb/src/test/resources/initialize-mongo-single.js66 print('Error, exiting!')CODE
HIGH…resources/mongodb/sharded/command-templates/init-rs.js9 print("is primary result: ", isPrimary);CODE
Excessive Try-Catch Wrapping5 hits · 8 pts
SeverityFileLineSnippetContext
MEDIUM…b/scripts/release-container-images/process-versions.py125 print("Error: No valid versions found", file=sys.stderr)CODE
MEDIUM⚡…b/scripts/release-container-images/process-versions.py190 print("Error: streams-count must be at least 1", file=sys.stderr)STRING
MEDIUM⚡…b/scripts/release-container-images/process-versions.py193 print("Error: tags-per-stream must be at least 1", file=sys.stderr)STRING
MEDIUM⚡…b/scripts/release-container-images/process-versions.py200 print("Error: No tags provided on stdin", file=sys.stderr)STRING
MEDIUM…b/scripts/release-container-images/process-versions.py211 print("Error: No valid streams found", file=sys.stderr)STRING
Docstring Block Structure1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…b/scripts/release-container-images/process-versions.py26 Parse version string (e.g., 'v2.7.3.Final' or '2.7.3.Final'). Args: version_str: Version sSTRING
Self-Referential Comments1 hit · 2 pts
SeverityFileLineSnippetContext
MEDIUM…rc/test/java/io/debezium/config/ConfigurationTest.java333 assertThat(ddlFilter.test("# Create the new ENTITY table which will be the parent of all other resource tables.\CODE
Example Usage Blocks1 hit · 1 pts
SeverityFileLineSnippetContext
LOW⚡jenkins-jobs/scripts/pre-release.sh4# Usage:COMMENT
Deep Nesting1 hit · 1 pts
SeverityFileLineSnippetContext
LOW…ipts/deploy-snapshots/build_and_deploy_repositories.py10CODE