@@ -380,7 +380,7 @@ public void setAckTime(long ackTime) {
380380 * Set the executor for threads that poll the consumer.
381381 * @param consumerTaskExecutor the executor
382382 */
383- public void setConsumerTaskExecutor (AsyncListenableTaskExecutor consumerTaskExecutor ) {
383+ public void setConsumerTaskExecutor (@ Nullable AsyncListenableTaskExecutor consumerTaskExecutor ) {
384384 this .consumerTaskExecutor = consumerTaskExecutor ;
385385 }
386386
@@ -418,7 +418,7 @@ public void setShutdownTimeout(long shutdownTimeout) {
418418 * no records and this interval has elapsed since a record was returned.
419419 * @param idleEventInterval the interval.
420420 */
421- public void setIdleEventInterval (Long idleEventInterval ) {
421+ public void setIdleEventInterval (@ Nullable Long idleEventInterval ) {
422422 this .idleEventInterval = idleEventInterval ;
423423 }
424424
@@ -427,7 +427,7 @@ public void setIdleEventInterval(Long idleEventInterval) {
427427 * no records for a partition and this interval has elapsed since a record was returned.
428428 * @param idlePartitionEventInterval the interval.
429429 */
430- public void setIdlePartitionEventInterval (Long idlePartitionEventInterval ) {
430+ public void setIdlePartitionEventInterval (@ Nullable Long idlePartitionEventInterval ) {
431431 this .idlePartitionEventInterval = idlePartitionEventInterval ;
432432 }
433433
@@ -519,7 +519,7 @@ public TaskScheduler getScheduler() {
519519 * @since 1.3.1
520520 * @see #setMonitorInterval(int)
521521 */
522- public void setScheduler (TaskScheduler scheduler ) {
522+ public void setScheduler (@ Nullable TaskScheduler scheduler ) {
523523 this .scheduler = scheduler ;
524524 }
525525
@@ -676,7 +676,7 @@ public Boolean getSubBatchPerPartition() {
676676 * @param subBatchPerPartition true for a separate transaction for each partition.
677677 * @since 2.3.2
678678 */
679- public void setSubBatchPerPartition (boolean subBatchPerPartition ) {
679+ public void setSubBatchPerPartition (@ Nullable boolean subBatchPerPartition ) {
680680 this .subBatchPerPartition = subBatchPerPartition ;
681681 }
682682
@@ -760,7 +760,7 @@ public TransactionDefinition getTransactionDefinition() {
760760 * @since 2.5.4
761761 * @see #setTransactionManager(PlatformTransactionManager)
762762 */
763- public void setTransactionDefinition (TransactionDefinition transactionDefinition ) {
763+ public void setTransactionDefinition (@ Nullable TransactionDefinition transactionDefinition ) {
764764 this .transactionDefinition = transactionDefinition ;
765765 }
766766
0 commit comments