Sonar Fixes

Author: garyrussell

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

@@ -394,8 +394,8 @@ protected static class CloseSafeProducer<K, V> implements Producer<K, V> {
 			this(delegate, cache, null);
 		}
 
-		CloseSafeProducer(Producer<K, V> delegate, BlockingQueue<CloseSafeProducer<K, V>> cache,
-				Consumer<CloseSafeProducer<K, V>> removeConsumerProducer) {
+		CloseSafeProducer(Producer<K, V> delegate, @Nullable BlockingQueue<CloseSafeProducer<K, V>> cache,
+				@Nullable Consumer<CloseSafeProducer<K, V>> removeConsumerProducer) {
 			this.delegate = delegate;
 			this.cache = cache;
 			this.removeConsumerProducer = removeConsumerProducer;

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

@@ -35,9 +35,9 @@ public final class CorrelationKey {
 
 	private volatile Integer hashCode;
 
-	public CorrelationKey(byte[] correlationId) {
+	public CorrelationKey(byte[] correlationId) { // NOSONAR array reference
 		Assert.notNull(correlationId, "'correlationId' cannot be null");
-		this.correlationId = correlationId;
+		this.correlationId = correlationId; // NOSONAR array reference
 	}
 
 	public byte[] getCorrelationId() {

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/DeserializationException.java

@@ -33,14 +33,14 @@ public class DeserializationException extends KafkaException {
 
 	private final boolean isKey;
 
-	public DeserializationException(String message, byte[] data, boolean isKey, Throwable cause) {
+	public DeserializationException(String message, byte[] data, boolean isKey, Throwable cause) { // NOSONAR array reference
 		super(message, cause);
-		this.data = data;
+		this.data = data; // NOSONAR array reference
 		this.isKey = isKey;
 	}
 
 	public byte[] getData() {
-		return this.data;
+		return this.data; // NOSONAR array reference
 	}
 
 	public boolean isKey() {