Skip to content

Commit 341de2b

Browse files
authored
Use SchemaInfo API to build SchemaInfo objects (#101)
1 parent 15a16b6 commit 341de2b

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

commons/src/main/java/com/datastax/oss/cdc/NativeSchemaWrapper.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
import org.apache.avro.Schema;
1919
import org.apache.pulsar.client.api.schema.SchemaInfoProvider;
20-
import org.apache.pulsar.client.impl.schema.SchemaInfoImpl;
2120
import org.apache.pulsar.common.schema.SchemaInfo;
2221
import org.apache.pulsar.common.schema.SchemaType;
2322

@@ -35,7 +34,7 @@ public class NativeSchemaWrapper implements org.apache.pulsar.client.api.Schema<
3534
public NativeSchemaWrapper(Schema nativeSchema, SchemaType pulsarSchemaType) {
3635
this.nativeSchema = nativeSchema;
3736
this.pulsarSchemaType = pulsarSchemaType;
38-
this.pulsarSchemaInfo = SchemaInfoImpl.builder()
37+
this.pulsarSchemaInfo = SchemaInfo.builder()
3938
.schema(nativeSchema.toString(false).getBytes(StandardCharsets.UTF_8))
4039
.properties(new HashMap<>())
4140
.type(pulsarSchemaType)

0 commit comments

Comments
 (0)