remove @SuppressWarnings("NullAway")

Signed-off-by: Jiandong Ma <[email protected]>

Author: mjd507

spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/PollableKafkaChannel.java

@@ -196,11 +196,10 @@ public boolean hasExecutorInterceptors() {
 		return this.executorInterceptorsSize > 0;
 	}
 
-	@SuppressWarnings("NullAway")
 	private static String topic(KafkaMessageSource<?, ?> source) {
 		Assert.notNull(source, "'source' cannot be null");
-		String[] topics = source.getConsumerProperties().getTopics();
-		Assert.isTrue(topics != null && topics.length == 1, "Only one topic is allowed");
+		@Nullable String @Nullable [] topics = source.getConsumerProperties().getTopics();
+		Assert.isTrue(topics != null && topics.length == 1 && topics[0] != null, "Only one topic is allowed");
 		return topics[0];
 	}
 

spring-integration-kafka/src/main/java/org/springframework/integration/kafka/channel/SubscribableKafkaChannel.java

@@ -179,7 +179,6 @@ public boolean unsubscribe(MessageHandler handler) {
 		return this.dispatcher.removeHandler(handler);
 	}
 
-	@SuppressWarnings("NullAway")
 	private class IntegrationRecordMessageListener extends RecordMessagingMessageListenerAdapter<Object, Object> {
 
 		IntegrationRecordMessageListener() {

spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java

@@ -281,7 +281,6 @@ protected AttributeAccessor getErrorMessageAttributes(@Nullable Message<?> messa
 		}
 	}
 
-	@SuppressWarnings("NullAway")
 	private class IntegrationRecordMessageListener extends RecordMessagingMessageListenerAdapter<K, V> {
 
 		IntegrationRecordMessageListener() {

spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java

@@ -422,7 +422,6 @@ public enum ListenerMode {
 		batch
 	}
 
-	@SuppressWarnings("NullAway")
 	private class IntegrationRecordMessageListener extends RecordMessagingMessageListenerAdapter<K, V> {
 
 		IntegrationRecordMessageListener() {
@@ -512,7 +511,6 @@ else if (KafkaMessageDrivenChannelAdapter.this.containerDeliveryAttemptPresent)
 
 	}
 
-	@SuppressWarnings("NullAway")
 	private class IntegrationBatchMessageListener extends BatchMessagingMessageListenerAdapter<K, V> {
 
 		IntegrationBatchMessageListener() {