diff --git a/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java b/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java
index e937837..643bd13 100644
--- a/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java
+++ b/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java
@@ -139,9 +139,7 @@ public void setBackPressureThreshold(long backPressureThreshold) {
 
 	/**
 	 * Configure a {@link MessageConverter} for converting payload to {@code byte[]} for Kinesis record.
-	 *
 	 * @param messageConverter the {@link MessageConverter} to use.
-	 *
 	 * @since 2.3
 	 */
 	public void setMessageConverter(MessageConverter messageConverter) {
@@ -196,12 +194,9 @@ public void setSequenceNumberExpression(Expression sequenceNumberExpression) {
 	/**
 	 * Specify a {@link OutboundMessageMapper} for embedding message headers into the
 	 * record data together with payload.
-	 *
 	 * @param embeddedHeadersMapper the {@link OutboundMessageMapper} to embed headers
 	 * into the record data.
-	 *
 	 * @since 2.0
-	 *
 	 * @see org.springframework.integration.support.json.EmbeddedJsonHeadersMessageMapper
 	 */
 	public void setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]> embeddedHeadersMapper) {
@@ -210,9 +205,7 @@ public void setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]> embeddedHeade
 
 	/**
 	 * Configure a {@link Duration} how often to call a {@link KinesisProducer#flush()}.
-	 *
 	 * @param flushDuration the {@link Duration} to periodic call of a {@link KinesisProducer#flush()}.
-	 *
 	 * @since 2.3.6
 	 */
 	public void setFlushDuration(Duration flushDuration) {
@@ -222,9 +215,7 @@ public void setFlushDuration(Duration flushDuration) {
 
 	/**
 	 * Unsupported operation. Use {@link #setEmbeddedHeadersMapper} instead.
-	 *
 	 * @param headerMapper is not used.
-	 *
 	 * @see #setEmbeddedHeadersMapper
 	 */
 	@Override
@@ -235,11 +226,8 @@ public void setHeaderMapper(HeaderMapper<Void> headerMapper) {
 
 	/**
 	 * Set a {@link Schema} to add into a {@link UserRecord} built from the request message.
-	 *
 	 * @param glueSchema the {@link Schema} to add into a {@link UserRecord}.
-	 *
 	 * @since 2.5.2
-	 *
 	 * @see UserRecord#setSchema(Schema)
 	 */
 	public void setGlueSchema(Schema glueSchema) {
@@ -249,11 +237,8 @@ public void setGlueSchema(Schema glueSchema) {
 	/**
 	 * Set a SpEL expression for {@link Schema} to add into a {@link UserRecord}
 	 * built from the request message.
-	 *
 	 * @param glueSchemaExpression the SpEL expression to evaluate a {@link Schema}.
-	 *
 	 * @since 2.5.2
-	 *
 	 * @see UserRecord#setSchema(Schema)
 	 */
 	public void setGlueSchemaExpressionString(String glueSchemaExpression) {
@@ -263,11 +248,8 @@ public void setGlueSchemaExpressionString(String glueSchemaExpression) {
 	/**
 	 * Set a SpEL expression for {@link Schema} to add into a {@link UserRecord}
 	 * built from the request message.
-	 *
 	 * @param glueSchemaExpression the SpEL expression to evaluate a {@link Schema}.
-	 *
 	 * @since 2.5.2
-	 *
 	 * @see UserRecord#setSchema(Schema)
 	 */
 	public void setGlueSchemaExpression(Expression glueSchemaExpression) {