Use o.a.pulsar.api.schema.KeyValueSchema instead of .impl.schema.KeyValueSchema

Author: Enrico Olivelli

producer-v3-pulsar/src/test/java/com/datastax/cassandra/cdc/producer/PulsarProducerV3Tests.java

@@ -23,9 +23,9 @@
 import org.apache.pulsar.client.api.*;
 import org.apache.pulsar.client.api.schema.Field;
 import org.apache.pulsar.client.api.schema.GenericRecord;
+import org.apache.pulsar.client.api.schema.KeyValueSchema;
 import org.apache.pulsar.client.api.schema.RecordSchemaBuilder;
 import org.apache.pulsar.client.api.schema.SchemaBuilder;
-import org.apache.pulsar.client.impl.schema.KeyValueSchema;
 import org.apache.pulsar.common.schema.KeyValue;
 import org.apache.pulsar.common.schema.KeyValueEncodingType;
 import org.apache.pulsar.common.schema.SchemaInfo;

producer-v4-pulsar/src/test/java/com/datastax/cassandra/cdc/producer/PulsarProducerV4Tests.java

@@ -23,9 +23,9 @@
 import org.apache.pulsar.client.api.*;
 import org.apache.pulsar.client.api.schema.Field;
 import org.apache.pulsar.client.api.schema.GenericRecord;
+import org.apache.pulsar.client.api.schema.KeyValueSchema;
 import org.apache.pulsar.client.api.schema.RecordSchemaBuilder;
 import org.apache.pulsar.client.api.schema.SchemaBuilder;
-import org.apache.pulsar.client.impl.schema.KeyValueSchema;
 import org.apache.pulsar.common.schema.KeyValue;
 import org.apache.pulsar.common.schema.KeyValueEncodingType;
 import org.apache.pulsar.common.schema.SchemaInfo;

source-pulsar/build.gradle

@@ -23,7 +23,7 @@ dependencies {
     implementation "com.datastax.oss:java-driver-core:${ossDriverVersion}"
     implementation "com.datastax.oss:java-driver-query-builder:${ossDriverVersion}"
 
-    compileOnly("org.apache.pulsar:pulsar-client-original:${pulsarVersion}")
+    compileOnly("org.apache.pulsar:pulsar-client-api:${pulsarVersion}")
     compileOnly("org.apache.pulsar:pulsar-io-common:${pulsarVersion}")
     compileOnly("org.apache.pulsar:pulsar-io-core:${pulsarVersion}")