From c863af447d1badd8369835bf04adec9386989a19 Mon Sep 17 00:00:00 2001 From: dogglezz Date: Wed, 13 Dec 2023 23:03:49 +0900 Subject: [PATCH] Fix typo in javadoc --- .../kafka/annotation/KafkaListenerConfigurer.java | 2 +- .../kafka/annotation/KafkaStreamsDefaultConfiguration.java | 2 +- .../org/springframework/kafka/annotation/PartitionOffset.java | 2 +- .../org/springframework/kafka/annotation/TopicPartition.java | 2 +- .../kafka/requestreply/AggregatingReplyingKafkaTemplate.java | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerConfigurer.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerConfigurer.java index 72f44b91d1..d79804009f 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerConfigurer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerConfigurer.java @@ -22,7 +22,7 @@ /** * Optional interface to be implemented by Spring managed bean willing * to customize how Kafka listener endpoints are configured. Typically - * used to defined the default + * used to define the default * {@link org.springframework.kafka.config.KafkaListenerContainerFactory * KafkaListenerContainerFactory} to use or for registering Kafka endpoints * in a programmatic fashion as opposed to the declarative diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java index 892aa67522..accb9e84f2 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java @@ -29,7 +29,7 @@ * {@code @Configuration} class that registers a {@link StreamsBuilderFactoryBean} * if {@link org.apache.kafka.streams.StreamsConfig} with the name * {@link KafkaStreamsDefaultConfiguration#DEFAULT_STREAMS_CONFIG_BEAN_NAME} is present - * in the application context. Otherwise a {@link UnsatisfiedDependencyException} is thrown. + * in the application context. Otherwise, a {@link UnsatisfiedDependencyException} is thrown. * *

This configuration class is automatically imported when using the @{@link EnableKafkaStreams} * annotation. See {@link EnableKafkaStreams} Javadoc for complete usage. diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/PartitionOffset.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/PartitionOffset.java index 8c92ba66eb..f779f9bb28 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/PartitionOffset.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/PartitionOffset.java @@ -36,7 +36,7 @@ * parsed as Integer). '*' indicates that the initial offset will be applied to all * partitions in the encompassing {@link TopicPartition} The string can contain a * comma-delimited list of partitions, or ranges of partitions (e.g. - * {@code 0-5, 7, 10-15}, in which case, the offset will be applied to all of those + * {@code 0-5, 7, 10-15}), in which case, the offset will be applied to all of those * partitions. * @return partition within the topic. */ diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/TopicPartition.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/TopicPartition.java index 99cadbc7e2..9c4d5b3d82 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/TopicPartition.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/TopicPartition.java @@ -42,7 +42,7 @@ /** * The partitions within the topic. Partitions specified here can't be duplicated in * {@link #partitionOffsets()}. Each string can contain a comma-delimited list of - * partitions, or ranges of partitions (e.g. {@code 0-5, 7, 10-15}. + * partitions, or ranges of partitions (e.g. {@code 0-5, 7, 10-15}). * @return the partitions within the topic. Property place holders and SpEL * expressions are supported, which must resolve to Integers (or Strings that can be * parsed as Integers). diff --git a/spring-kafka/src/main/java/org/springframework/kafka/requestreply/AggregatingReplyingKafkaTemplate.java b/spring-kafka/src/main/java/org/springframework/kafka/requestreply/AggregatingReplyingKafkaTemplate.java index 585fe4f687..0bfebbe0e5 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/requestreply/AggregatingReplyingKafkaTemplate.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/requestreply/AggregatingReplyingKafkaTemplate.java @@ -91,7 +91,7 @@ public class AggregatingReplyingKafkaTemplate * @param replyContainer the reply container. * @param releaseStrategy the release strategy which is a {@link BiPredicate} which is * passed the current list and a boolean to indicate if this is for a normal delivery - * or a timeout (when {@link #setReturnPartialOnTimeout(boolean)} is true. The + * or a timeout (when {@link #setReturnPartialOnTimeout(boolean)} is true). The * predicate may modify the list of records. * @since 2.3.5 */