diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java
index 0a8c72173..fe40d05e6 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java
@@ -30,7 +30,7 @@ import org.apache.kafka.streams.StreamsConfig;
 import org.springframework.kafka.config.StreamsBuilderFactoryBean;
 
 /**
- * An internal registry for holding {@KafkaStreams} objects maintained through
+ * An internal registry for holding {@link KafkaStreams} objects maintained through
  * {@link StreamsBuilderFactoryManager}.
  *
  * @author Soby Chacko
diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java
index 01573d20e..ce217baf7 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java
@@ -52,14 +52,14 @@ import org.springframework.kafka.support.serializer.JsonSerde;
  *
  * <pre class="code">
  *		.aggregate(ArrayList::new,
- * 					(k, v, aggregates) -> {
+ * 					(k, v, aggregates) -&gt; {
  * 							aggregates.add(v);
  * 							return aggregates;
  *                                                },
  * 					Materialized.&lt;String, Collection&lt;Foo&gt;, WindowStore&lt;Bytes, byte[]&gt;&gt;as(
  * 						"foo-store")
  * 						.withKeySerde(Serdes.String())
- *						.withValueSerde(new CollectionSerde<>(Foo.class, ArrayList.class)))
+ *						.withValueSerde(new CollectionSerde&lt;&gt;(Foo.class, ArrayList.class)))
  *  * </pre>
  *
  * Supported Collection types by this Serde are - {@link java.util.ArrayList}, {@link java.util.LinkedList},
diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java
index ddfe65ff7..a7b0300ac 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java
@@ -23,9 +23,9 @@ import org.springframework.messaging.converter.CompositeMessageConverter;
  * It is kept for backward compatibility reasons and will be removed in version 3.1
  *
  * @author Soby Chacko
- * @sine 2.1
+ * @since 2.1
  *
- * @deprecated in favour of {@link MessageConverterDelegateSerde}
+ * @deprecated in favor of {@link MessageConverterDelegateSerde}
  */
 @Deprecated
 public class CompositeNonNativeSerde extends MessageConverterDelegateSerde {