@@ -1059,6 +1059,7 @@ public String toString() {
1059
1059
+ "\n ackMode=" + this .ackMode
1060
1060
+ "\n ackCount=" + this .ackCount
1061
1061
+ "\n ackTime=" + this .ackTime
1062
+ + "\n consumerStartTimeout=" + this .consumerStartTimeout
1062
1063
+ "\n messageListener=" + this .messageListener
1063
1064
+ (this .listenerTaskExecutor != null
1064
1065
? "\n listenerTaskExecutor=" + this .listenerTaskExecutor
@@ -1074,16 +1075,21 @@ public String toString() {
1074
1075
+ "\n monitorInterval=" + this .monitorInterval
1075
1076
+ (this .scheduler != null ? "\n scheduler=" + this .scheduler : "" )
1076
1077
+ "\n noPollThreshold=" + this .noPollThreshold
1078
+ + "\n pauseImmediate=" + this .pauseImmediate
1077
1079
+ "\n pollTimeoutWhilePaused=" + this .pollTimeoutWhilePaused
1078
1080
+ "\n subBatchPerPartition=" + this .subBatchPerPartition
1079
1081
+ "\n assignmentCommitOption=" + this .assignmentCommitOption
1080
1082
+ "\n deliveryAttemptHeader=" + this .deliveryAttemptHeader
1083
+ + "\n batchRecoverAfterRollback=" + this .batchRecoverAfterRollback
1081
1084
+ "\n eosMode=" + this .eosMode
1082
1085
+ "\n transactionDefinition=" + this .transactionDefinition
1083
1086
+ "\n stopContainerWhenFenced=" + this .stopContainerWhenFenced
1084
1087
+ "\n stopImmediate=" + this .stopImmediate
1085
1088
+ "\n asyncAcks=" + this .asyncAcks
1089
+ + "\n logContainerConfig=" + this .logContainerConfig
1090
+ + "\n missingTopicsFatal=" + this .missingTopicsFatal
1086
1091
+ "\n idleBeforeDataMultiplier=" + this .idleBeforeDataMultiplier
1092
+ + "\n idleBetweenPolls=" + this .idleBetweenPolls
1087
1093
+ "\n micrometerEnabled=" + this .micrometerEnabled
1088
1094
+ "\n observationEnabled=" + this .observationEnabled
1089
1095
+ (this .observationConvention != null
0 commit comments