@@ -380,7 +380,7 @@ public void setAckTime(long ackTime) {
380
380
* Set the executor for threads that poll the consumer.
381
381
* @param consumerTaskExecutor the executor
382
382
*/
383
- public void setConsumerTaskExecutor (AsyncListenableTaskExecutor consumerTaskExecutor ) {
383
+ public void setConsumerTaskExecutor (@ Nullable AsyncListenableTaskExecutor consumerTaskExecutor ) {
384
384
this .consumerTaskExecutor = consumerTaskExecutor ;
385
385
}
386
386
@@ -418,7 +418,7 @@ public void setShutdownTimeout(long shutdownTimeout) {
418
418
* no records and this interval has elapsed since a record was returned.
419
419
* @param idleEventInterval the interval.
420
420
*/
421
- public void setIdleEventInterval (Long idleEventInterval ) {
421
+ public void setIdleEventInterval (@ Nullable Long idleEventInterval ) {
422
422
this .idleEventInterval = idleEventInterval ;
423
423
}
424
424
@@ -427,7 +427,7 @@ public void setIdleEventInterval(Long idleEventInterval) {
427
427
* no records for a partition and this interval has elapsed since a record was returned.
428
428
* @param idlePartitionEventInterval the interval.
429
429
*/
430
- public void setIdlePartitionEventInterval (Long idlePartitionEventInterval ) {
430
+ public void setIdlePartitionEventInterval (@ Nullable Long idlePartitionEventInterval ) {
431
431
this .idlePartitionEventInterval = idlePartitionEventInterval ;
432
432
}
433
433
@@ -519,7 +519,7 @@ public TaskScheduler getScheduler() {
519
519
* @since 1.3.1
520
520
* @see #setMonitorInterval(int)
521
521
*/
522
- public void setScheduler (TaskScheduler scheduler ) {
522
+ public void setScheduler (@ Nullable TaskScheduler scheduler ) {
523
523
this .scheduler = scheduler ;
524
524
}
525
525
@@ -676,7 +676,7 @@ public Boolean getSubBatchPerPartition() {
676
676
* @param subBatchPerPartition true for a separate transaction for each partition.
677
677
* @since 2.3.2
678
678
*/
679
- public void setSubBatchPerPartition (boolean subBatchPerPartition ) {
679
+ public void setSubBatchPerPartition (@ Nullable boolean subBatchPerPartition ) {
680
680
this .subBatchPerPartition = subBatchPerPartition ;
681
681
}
682
682
@@ -760,7 +760,7 @@ public TransactionDefinition getTransactionDefinition() {
760
760
* @since 2.5.4
761
761
* @see #setTransactionManager(PlatformTransactionManager)
762
762
*/
763
- public void setTransactionDefinition (TransactionDefinition transactionDefinition ) {
763
+ public void setTransactionDefinition (@ Nullable TransactionDefinition transactionDefinition ) {
764
764
this .transactionDefinition = transactionDefinition ;
765
765
}
766
766
0 commit comments