diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java index 34fc3788c3..9153cac0ef 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java @@ -381,7 +381,7 @@ public void setAckTime(long ackTime) { * Set the executor for threads that poll the consumer. * @param consumerTaskExecutor the executor */ - public void setConsumerTaskExecutor(AsyncListenableTaskExecutor consumerTaskExecutor) { + public void setConsumerTaskExecutor(@Nullable AsyncListenableTaskExecutor consumerTaskExecutor) { this.consumerTaskExecutor = consumerTaskExecutor; } @@ -419,7 +419,7 @@ public void setShutdownTimeout(long shutdownTimeout) { * no records and this interval has elapsed since a record was returned. * @param idleEventInterval the interval. */ - public void setIdleEventInterval(Long idleEventInterval) { + public void setIdleEventInterval(@Nullable Long idleEventInterval) { this.idleEventInterval = idleEventInterval; } @@ -428,7 +428,7 @@ public void setIdleEventInterval(Long idleEventInterval) { * no records for a partition and this interval has elapsed since a record was returned. * @param idlePartitionEventInterval the interval. */ - public void setIdlePartitionEventInterval(Long idlePartitionEventInterval) { + public void setIdlePartitionEventInterval(@Nullable Long idlePartitionEventInterval) { this.idlePartitionEventInterval = idlePartitionEventInterval; } @@ -520,7 +520,7 @@ public TaskScheduler getScheduler() { * @since 1.3.1 * @see #setMonitorInterval(int) */ - public void setScheduler(TaskScheduler scheduler) { + public void setScheduler(@Nullable TaskScheduler scheduler) { this.scheduler = scheduler; } @@ -677,7 +677,7 @@ public Boolean getSubBatchPerPartition() { * @param subBatchPerPartition true for a separate transaction for each partition. * @since 2.3.2 */ - public void setSubBatchPerPartition(boolean subBatchPerPartition) { + public void setSubBatchPerPartition(@Nullable boolean subBatchPerPartition) { this.subBatchPerPartition = subBatchPerPartition; } @@ -761,7 +761,7 @@ public TransactionDefinition getTransactionDefinition() { * @since 2.5.4 * @see #setTransactionManager(PlatformTransactionManager) */ - public void setTransactionDefinition(TransactionDefinition transactionDefinition) { + public void setTransactionDefinition(@Nullable TransactionDefinition transactionDefinition) { this.transactionDefinition = transactionDefinition; }