polishing

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>

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>

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>

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);

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>