SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing javadoc errors

Browse Source 
Resovles https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/915
This commit is contained in:
Soby Chacko
2020-06-16 18:37:07 -04:00
parent a549810899
commit dc7c8d657a
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsRegistry.java
View File

@@ -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

4
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CollectionSerde.java
View File

@@ -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},

4
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/serde/CompositeNonNativeSerde.java
View File

@@ -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 {