You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2023/06/22 08:04:39 UTC
[flink] branch master updated: [FLINK-31731] Add backwards compatible constructor for DebeziumAvroSerializationSchema
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 274aa0debff [FLINK-31731] Add backwards compatible constructor for DebeziumAvroSerializationSchema
274aa0debff is described below
commit 274aa0debffaa57926c474f11e36be753b49cbc5
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Sat Jun 17 11:18:22 2023 -0700
[FLINK-31731] Add backwards compatible constructor for DebeziumAvroSerializationSchema
This closes #22817.
---
.../confluent/debezium/DebeziumAvroSerializationSchema.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSchema.java b/flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSchema.java
index a5b4eb7ab09..b72a68efb98 100644
--- a/flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSchema.java
+++ b/flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSchema.java
@@ -62,6 +62,14 @@ public class DebeziumAvroSerializationSchema implements SerializationSchema<RowD
private transient GenericRowData outputReuse;
+ public DebeziumAvroSerializationSchema(
+ RowType rowType,
+ String schemaRegistryUrl,
+ String schemaRegistrySubject,
+ @Nullable Map<String, ?> registryConfigs) {
+ this(rowType, schemaRegistryUrl, schemaRegistrySubject, null, registryConfigs);
+ }
+
public DebeziumAvroSerializationSchema(
RowType rowType,
String schemaRegistryUrl,