diff --git a/kafka-e2e-kotlin-sample/customer-service/pom.xml b/kafka-e2e-kotlin-sample/customer-service/pom.xml
index 9dcacc0..286b636 100644
--- a/kafka-e2e-kotlin-sample/customer-service/pom.xml
+++ b/kafka-e2e-kotlin-sample/customer-service/pom.xml
@@ -56,6 +56,7 @@
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-stream-schema</artifactId>
+            <version>3.0.0.BUILD-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/kafka-e2e-kotlin-sample/order-service/pom.xml b/kafka-e2e-kotlin-sample/order-service/pom.xml
index 78f8fcd..44c9783 100644
--- a/kafka-e2e-kotlin-sample/order-service/pom.xml
+++ b/kafka-e2e-kotlin-sample/order-service/pom.xml
@@ -56,6 +56,7 @@
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-stream-schema</artifactId>
+            <version>3.0.0.BUILD-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/kafka-e2e-kotlin-sample/shipping-service/pom.xml b/kafka-e2e-kotlin-sample/shipping-service/pom.xml
index 50d1ce3..445537d 100644
--- a/kafka-e2e-kotlin-sample/shipping-service/pom.xml
+++ b/kafka-e2e-kotlin-sample/shipping-service/pom.xml
@@ -56,6 +56,7 @@
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-stream-schema</artifactId>
+            <version>3.0.0.BUILD-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/schema-registry-samples/schema-registry-vanilla-kafka-binder/kafka-streams-consumer/src/main/java/sample/consumer/CountVersionApplication.java b/schema-registry-samples/schema-registry-vanilla-kafka-binder/kafka-streams-consumer/src/main/java/sample/consumer/CountVersionApplication.java
index 697087e..4da0e59 100644
--- a/schema-registry-samples/schema-registry-vanilla-kafka-binder/kafka-streams-consumer/src/main/java/sample/consumer/CountVersionApplication.java
+++ b/schema-registry-samples/schema-registry-vanilla-kafka-binder/kafka-streams-consumer/src/main/java/sample/consumer/CountVersionApplication.java
@@ -21,6 +21,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.schema.registry.client.EnableSchemaRegistryClient;
 import org.springframework.cloud.stream.binder.kafka.streams.InteractiveQueryService;
 import org.springframework.cloud.stream.binder.kafka.streams.serde.CompositeNonNativeSerde;
+import org.springframework.cloud.stream.binder.kafka.streams.serde.MessageConverterDelegateSerde;
 import org.springframework.context.annotation.Bean;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -42,7 +43,7 @@ public class CountVersionApplication {
      * Avro message converter used by the inbound serialization by the framework. This Serde implementation
      * will interact with the Spring Cloud Stream provided Schema Registry for resolving schema. */
     @Autowired
-    private CompositeNonNativeSerde<Sensor> customSerde;
+    private MessageConverterDelegateSerde<Sensor> customSerde;
 
     public static void main(String[] args) {
         SpringApplication.run(CountVersionApplication.class, args);
diff --git a/transaction-kafka-samples/transaction-http-source/pom.xml b/transaction-kafka-samples/transaction-http-source/pom.xml
index f0b09d5..6e3a1c0 100644
--- a/transaction-kafka-samples/transaction-http-source/pom.xml
+++ b/transaction-kafka-samples/transaction-http-source/pom.xml
@@ -20,6 +20,7 @@
     <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-stream-schema</artifactId>
+      <version>3.0.0.BUILD-SNAPSHOT</version>
     </dependency>
     <dependency>
       <groupId>org.springframework.cloud</groupId>