Fix unused import

* Fix new Sonar smells

Author: artembilan

spring-integration-r2dbc/src/main/java/org/springframework/integration/r2dbc/inbound/R2dbcMessageSource.java

@@ -17,7 +17,6 @@
 package org.springframework.integration.r2dbc.inbound;
 
 
-import java.util.HashMap;
 import java.util.Map;
 import java.util.function.BiFunction;
 

spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducer.java

@@ -25,9 +25,7 @@
 import org.springframework.data.redis.connection.stream.StreamOffset;
 import org.springframework.data.redis.core.ReactiveRedisTemplate;
 import org.springframework.data.redis.core.ReactiveStreamOperations;
-import org.springframework.data.redis.core.StreamOperations;
 import org.springframework.data.redis.serializer.RedisSerializationContext;
-import org.springframework.data.redis.serializer.StringRedisSerializer;
 import org.springframework.data.redis.stream.StreamReceiver;
 import org.springframework.integration.IntegrationMessageHeaderAccessor;
 import org.springframework.integration.endpoint.MessageProducerSupport;
@@ -146,9 +144,10 @@ public void setCreateConsumerGroup(boolean createConsumerGroup) {
 	}
 
 	/**
-	 * Set {@link StreamOperations} used to customize the {@link StreamReceiver}.
+	 * Set {@link ReactiveStreamOperations} used to customize the {@link StreamReceiver}.
 	 * It provides a way to set the polling timeout and the serialization context.
-	 * By default the polling timeout is set to infinite and {@link StringRedisSerializer} is used.
+	 * By default the polling timeout is set to infinite and
+	 * {@link org.springframework.data.redis.serializer.StringRedisSerializer} is used.
 	 * @param streamReceiverOptions the desired receiver options
 	 * */
 	public void setStreamReceiverOptions(