Package io.confluent.kafka.schemaregistry.type.logical.avro

Class LogicalTypeToAvroConverter

java.lang.Object

io.confluent.kafka.schemaregistry.type.logical.avro.LogicalTypeToAvroConverter

public class LogicalTypeToAvroConverter
extends Object

Converts logical type Schema to Avro Schema.

Constructor Summary

Constructors

Constructor	Description
LogicalTypeToAvroConverter()

Method Summary

Modifier and Type	Method	Description
static AvroSchema	fromLogicalType(LogicalType logicalType, String rowName)	Converts a logical type schema into an Avro schema using the canonical (V2) emission.
static AvroSchema	fromLogicalType(LogicalType logicalType, String rowName, LogicalTypeVersion version)	Converts a logical type schema into an Avro schema in the requested emission edition (V1 = Flink-compatible; V2 = canonical LT).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LogicalTypeToAvroConverter

public LogicalTypeToAvroConverter()

Method Details

fromLogicalType

public static AvroSchema fromLogicalType(LogicalType logicalType,
 String rowName)

Converts a logical type schema into an Avro schema using the canonical (V2) emission. Prefer the explicit-version overload for new callers.

fromLogicalType

public static AvroSchema fromLogicalType(LogicalType logicalType,
 String rowName,
 LogicalTypeVersion version)

Converts a logical type schema into an Avro schema in the requested emission edition (V1 = Flink-compatible; V2 = canonical LT).