diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/ReceiverOptionsCustomizer.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/ReceiverOptionsCustomizer.java index 022af1953..f00fabe71 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/ReceiverOptionsCustomizer.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/ReceiverOptionsCustomizer.java @@ -21,12 +21,12 @@ import java.util.function.BiFunction; import reactor.kafka.receiver.ReceiverOptions; import org.springframework.core.Ordered; -import org.springframework.core.annotation.Order; /** * Customizer for {@link ReceiverOptions}; the first parameter contains the binder name; * the second is the {@link ReceiverOptions} to customize. Return the customized - * {@link ReceiverOptions}. Applied in {@link Order} if multiple customizers are found. + * {@link ReceiverOptions}. Applied in {@link Ordered order} if multiple customizers are + * found. * * @author Gary Russell * @since 4.0.2 diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/SenderOptionsCustomizer.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/SenderOptionsCustomizer.java index 52ff2f59d..0f43af6a4 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/SenderOptionsCustomizer.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/SenderOptionsCustomizer.java @@ -21,12 +21,12 @@ import java.util.function.BiFunction; import reactor.kafka.sender.SenderOptions; import org.springframework.core.Ordered; -import org.springframework.core.annotation.Order; /** * Customizer for {@link SenderOptions}; the first parameter contains the binder name; the * second is the {@link SenderOptions} to customize. Return the customized - * {@link SenderOptions}. Applied in {@link Order} if multiple customizers are found. + * {@link SenderOptions}. Applied in {@link Ordered order} if multiple customizers are + * found. * * @author Gary Russell * @since 4.0.2