@@ -381,7 +381,7 @@ public void setAckTime(long ackTime) {
381381 * Set the executor for threads that poll the consumer.
382382 * @param consumerTaskExecutor the executor
383383 */
384- public void setConsumerTaskExecutor (AsyncListenableTaskExecutor consumerTaskExecutor ) {
384+ public void setConsumerTaskExecutor (@ Nullable AsyncListenableTaskExecutor consumerTaskExecutor ) {
385385 this .consumerTaskExecutor = consumerTaskExecutor ;
386386 }
387387
@@ -419,7 +419,7 @@ public void setShutdownTimeout(long shutdownTimeout) {
419419 * no records and this interval has elapsed since a record was returned.
420420 * @param idleEventInterval the interval.
421421 */
422- public void setIdleEventInterval (Long idleEventInterval ) {
422+ public void setIdleEventInterval (@ Nullable Long idleEventInterval ) {
423423 this .idleEventInterval = idleEventInterval ;
424424 }
425425
@@ -428,7 +428,7 @@ public void setIdleEventInterval(Long idleEventInterval) {
428428 * no records for a partition and this interval has elapsed since a record was returned.
429429 * @param idlePartitionEventInterval the interval.
430430 */
431- public void setIdlePartitionEventInterval (Long idlePartitionEventInterval ) {
431+ public void setIdlePartitionEventInterval (@ Nullable Long idlePartitionEventInterval ) {
432432 this .idlePartitionEventInterval = idlePartitionEventInterval ;
433433 }
434434
@@ -520,7 +520,7 @@ public TaskScheduler getScheduler() {
520520 * @since 1.3.1
521521 * @see #setMonitorInterval(int)
522522 */
523- public void setScheduler (TaskScheduler scheduler ) {
523+ public void setScheduler (@ Nullable TaskScheduler scheduler ) {
524524 this .scheduler = scheduler ;
525525 }
526526
@@ -677,7 +677,7 @@ public Boolean getSubBatchPerPartition() {
677677 * @param subBatchPerPartition true for a separate transaction for each partition.
678678 * @since 2.3.2
679679 */
680- public void setSubBatchPerPartition (boolean subBatchPerPartition ) {
680+ public void setSubBatchPerPartition (@ Nullable boolean subBatchPerPartition ) {
681681 this .subBatchPerPartition = subBatchPerPartition ;
682682 }
683683
@@ -761,7 +761,7 @@ public TransactionDefinition getTransactionDefinition() {
761761 * @since 2.5.4
762762 * @see #setTransactionManager(PlatformTransactionManager)
763763 */
764- public void setTransactionDefinition (TransactionDefinition transactionDefinition ) {
764+ public void setTransactionDefinition (@ Nullable TransactionDefinition transactionDefinition ) {
765765 this .transactionDefinition = transactionDefinition ;
766766 }
767767
0 commit comments