GH-2357: Fix Sonar Issues

Author: garyrussell

spring-kafka/src/main/java/org/springframework/kafka/core/KafkaOperations.java

@@ -369,8 +369,6 @@ default ConsumerRecords<K, V> receive(Collection<TopicPartitionOffset> requested
 	default KafkaOperations2<K, V> usingCompletableFuture() {
 		return new KafkaOperations2<K, V>() {
 
-			KafkaOperations<K, V> ops;
-
 			@Override
 			public CompletableFuture<SendResult<K, V>> sendDefault(V data) {
 				return KafkaOperations.this.sendDefault(data).completable();
@@ -499,7 +497,7 @@ public ConsumerRecords<K, V> receive(Collection<TopicPartitionOffset> requested,
 
 		};
 
-	}
+	} // NOSONAR method line count
 
 	/**
 	 * A callback for executing arbitrary operations on the {@link Producer}.

spring-kafka/src/main/java/org/springframework/kafka/requestreply/RequestReplyTypedMessageFuture.java

@@ -39,19 +39,21 @@
  */
 public class RequestReplyTypedMessageFuture<K, V, P> extends RequestReplyMessageFuture<K, V> {
 
+	private static final String UNCHECKED = "unchecked";
+
 	private Completable completable;
 
 	RequestReplyTypedMessageFuture(ListenableFuture<SendResult<K, V>> sendFuture) {
 		super(sendFuture);
 	}
 
-	@SuppressWarnings("unchecked")
+	@SuppressWarnings(UNCHECKED)
 	@Override
 	public Message<P> get() throws InterruptedException, ExecutionException {
 		return (Message<P>) super.get();
 	}
 
-	@SuppressWarnings("unchecked")
+	@SuppressWarnings(UNCHECKED)
 	@Override
 	public Message<P> get(long timeout, TimeUnit unit)
 			throws InterruptedException, ExecutionException, TimeoutException {
@@ -74,17 +76,17 @@ public synchronized Completable asCompletable() {
 	 */
 	public class Completable extends RequestReplyMessageFuture.Completable {
 
-		Completable(RequestReplyMessageFuture requestReplyMessageFuture, Future delegate) {
+		Completable(RequestReplyMessageFuture requestReplyMessageFuture, Future<Message<?>> delegate) { // NOSONAR
 			requestReplyMessageFuture.super(delegate);
 		}
 
-		@SuppressWarnings("unchecked")
+		@SuppressWarnings(UNCHECKED)
 		@Override
 		public Message<P> get() throws InterruptedException, ExecutionException {
 			return (Message<P>) super.get();
 		}
 
-		@SuppressWarnings("unchecked")
+		@SuppressWarnings(UNCHECKED)
 		@Override
 		public Message<P> get(long timeout, TimeUnit unit)
 				throws InterruptedException, ExecutionException, TimeoutException {