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