侦听器容器属性 (Listener Container Properties) _ Spring for Apache Kafka 3.1.7-SNAPSHOT 中文文档(官方文档中文翻译) —

表 1. 性能`ContainerProperties`
财产	违约	描述
`ackCount`Spring中文文档	1Spring中文文档	提交挂起偏移量之前的记录数，当为或 .`ackModeCOUNTCOUNT_TIME`Spring中文文档
`adviceChain`Spring中文文档	`null`Spring中文文档	一连串的对象（例如围绕建议）包装消息侦听器，按顺序调用。`AdviceMethodInterceptor`Spring中文文档
`ackMode`Spring中文文档	批Spring中文文档	控制提交偏移量的频率 - 请参阅提交偏移量。Spring中文文档
`ackTime`Spring中文文档	5000Spring中文文档	当为或时，提交挂起偏移量的时间（以毫秒为单位）。`ackModeTIMECOUNT_TIME`Spring中文文档
`assignmentCommitOption`Spring中文文档	LATEST_ONLY _NO_TXSpring中文文档	是否在外派时承诺初始职位;默认情况下，仅当是时才会提交初始偏移量，即使存在事务管理器，它也不会在事务中运行。有关可用选项的更多信息，请参见 JavaDocs。`ConsumerConfig.AUTO_OFFSET_RESET_CONFIGlatestContainerProperties.AssignmentCommitOption`Spring中文文档
`asyncAcks`Spring中文文档	`false`Spring中文文档	启用无序提交（请参阅手动提交偏移量）;使用者将暂停并推迟提交，直到填补空白。Spring中文文档
`authExceptionRetryInterval`Spring中文文档	`null`Spring中文文档	如果不为 null，则当 Kafka 客户端抛出 or 时，a 在轮询之间休眠。如果为 null，则此类异常被视为致命异常，容器将停止。`DurationAuthenticationExceptionAuthorizationException`Spring中文文档
`batchRecoverAfterRollback`Spring中文文档	`false`Spring中文文档	设置为要启用批量恢复，请参阅回滚处理器之后。`true`Spring中文文档
`clientId`Spring中文文档	（空字符串）Spring中文文档	使用者属性的前缀。覆盖消费工厂属性;在并发容器中，作为每个使用者实例的后缀添加。`client.idclient.id-n`Spring中文文档
`checkDeserExWhenKeyNull`Spring中文文档	假Spring中文文档	设置为在收到 a 时始终检查标头。当使用者代码无法确定是否已配置时（例如使用委派反序列化程序时），很有用。`trueDeserializationExceptionnullkeyErrorHandlingDeserializer`Spring中文文档
`checkDeserExWhenValueNull`Spring中文文档	假Spring中文文档	设置为在收到 a 时始终检查标头。当使用者代码无法确定是否已配置时（例如使用委派反序列化程序时），很有用。`trueDeserializationExceptionnullvalueErrorHandlingDeserializer`Spring中文文档
`commitCallback`Spring中文文档	`null`Spring中文文档	如果存在，并且是提交完成后调用的回调。`syncCommitsfalse`Spring中文文档
`commitLogLevel`Spring中文文档	调试Spring中文文档	与提交偏移量相关的日志的日志记录级别。Spring中文文档
`consumerRebalanceListener`Spring中文文档	`null`Spring中文文档	再平衡侦听器;请参阅重新平衡侦听器。Spring中文文档
`commitRetries`Spring中文文档	3Spring中文文档	使用 set 设置为 true 时的重试次数。默认值为 3（总共 4 次尝试）。`RetriableCommitFailedExceptionsyncCommits`Spring中文文档
`consumerStartTimeout`Spring中文文档	30年代Spring中文文档	在记录错误之前等待使用者启动的时间;例如，如果您使用线程不足的任务执行程序，则可能会发生这种情况。Spring中文文档
`deliveryAttemptHeader`Spring中文文档	`false`Spring中文文档	请参阅投放尝试标头。Spring中文文档
`eosMode`Spring中文文档	`V2`Spring中文文档	Exactly Once 语义模式;请参阅 Exactly Once Semantics。Spring中文文档
`fixTxOffsets`Spring中文文档	`false`Spring中文文档	当使用由事务生产者生成的记录时，并且使用者位于分区的末尾，由于用于指示事务提交/回滚的伪记录，并且可能存在回滚记录，因此可能会错误地将滞后报告为大于零。这在功能上不会影响消费者，但一些用户表示担心“滞后”不为零。将此属性设置为，容器将更正此类错误报告的偏移量。该检查在下一次轮询之前执行，以避免显著增加提交处理的复杂性。在撰写本文时，仅当使用者配置为 1 且大于 1 时，才会纠正滞后。有关详细信息，请参阅 KAFKA-10683。`trueisolation.level=read_committedmax.poll.records`Spring中文文档
`groupId`Spring中文文档	`null`Spring中文文档	覆盖消费者财产;由 or 属性自动设置。`group.id@KafkaListeneridgroupId`Spring中文文档
`idleBeforeDataMultiplier`Spring中文文档	5.0Spring中文文档	在收到任何记录之前应用乘数。收到记录后，将不再应用乘数。从 2.8 版开始可用。`idleEventInterval`Spring中文文档
`idleBetweenPolls`Spring中文文档	0Spring中文文档	用于通过在投票之间休眠线程来减慢交付速度。处理一批记录加上此值的时间必须小于使用者属性。`max.poll.interval.ms`Spring中文文档
`idleEventInterval`Spring中文文档	`null`Spring中文文档	设置后，启用 s 的发布，请参阅应用程序事件和检测空闲和无响应使用者。另请参见。`ListenerContainerIdleEventidleBeforeDataMultiplier`Spring中文文档
`idlePartitionEventInterval`Spring中文文档	`null`Spring中文文档	设置后，启用 s 的发布，请参阅应用程序事件和检测空闲和无响应使用者。`ListenerContainerIdlePartitionEvent`Spring中文文档
`kafkaConsumerProperties`Spring中文文档	没有Spring中文文档	用于覆盖在使用者工厂上配置的任何任意使用者属性。Spring中文文档
`kafkaAwareTransactionManager`Spring中文文档	`null`Spring中文文档	请参阅交易记录。Spring中文文档
`listenerTaskExecutor`Spring中文文档	`SimpleAsyncTaskExecutor`Spring中文文档	用于运行使用者线程的任务执行器。默认执行程序创建名为的线程;其中，名称是 Bean 名称;with the name 是后缀为 bean 名称，其中 n 为每个子容器递增。`<name>-C-nKafkaMessageListenerContainerConcurrentMessageListenerContainer-n`Spring中文文档
`logContainerConfig`Spring中文文档	`false`Spring中文文档	设置为在 INFO 级别记录所有容器属性。`true`Spring中文文档
`messageListener`Spring中文文档	`null`Spring中文文档	消息侦听器。Spring中文文档
`micrometerEnabled`Spring中文文档	`true`Spring中文文档	是否为消费类线程维护千分尺计时器。Spring中文文档
`micrometerTags`Spring中文文档	空Spring中文文档	要添加到千分米指标的静态标签图。Spring中文文档
`micrometerTagsProvider`Spring中文文档	`null`Spring中文文档	根据消费者记录提供动态标签的函数。Spring中文文档
`missingTopicsFatal`Spring中文文档	`false`Spring中文文档	当 true 时，如果代理上不存在配置的主题，则阻止容器启动。Spring中文文档
`monitorInterval`Spring中文文档	30年代Spring中文文档	多久检查一次使用者线程的状态。请参见和。`NonResponsiveConsumerEventnoPollThresholdpollTimeout`Spring中文文档
`noPollThreshold`Spring中文文档	3.0Spring中文文档	乘以以确定是否发布 . 看。`pollTimeOutNonResponsiveConsumerEventmonitorInterval`Spring中文文档
`observationConvention`Spring中文文档	`null`Spring中文文档	设置后，根据消费者记录中的信息向计时器和跟踪添加动态标签。Spring中文文档
`observationEnabled`Spring中文文档	`false`Spring中文文档	设置为允许通过千分尺进行观察。`true`Spring中文文档
`offsetAndMetadataProvider`Spring中文文档	`null`Spring中文文档	的提供程序 ;默认情况下，提供程序使用空元数据创建偏移量和元数据。提供程序提供了一种自定义元数据的方法。`OffsetAndMetadata`Spring中文文档
`onlyLogRecordMetadata`Spring中文文档	`false`Spring中文文档	设置为记录完整的使用者记录（错误、调试日志等），而不仅仅是。`falsetopic-partition@offset`Spring中文文档
`pauseImmediate`Spring中文文档	`false`Spring中文文档	当容器暂停时，在当前记录之后停止处理，而不是在处理上一个轮询的所有记录后停止处理;其余记录保留在内存中，并在恢复容器时传递给侦听器。Spring中文文档
`pollTimeout`Spring中文文档	5000Spring中文文档	超时以毫秒为单位传递。`Consumer.poll()`Spring中文文档
`pollTimeoutWhilePaused`Spring中文文档	100Spring中文文档	当容器处于暂停状态时传递的超时（以毫秒为单位）。`Consumer.poll()`Spring中文文档
`restartAfterAuthExceptions`Spring中文文档	假Spring中文文档	如果容器因授权/身份验证异常而停止，则为 True 以重新启动容器。Spring中文文档
`scheduler`Spring中文文档	`ThreadPoolTaskScheduler`Spring中文文档	运行使用者监视任务的调度程序。Spring中文文档
`shutdownTimeout`Spring中文文档	10000Spring中文文档	在所有使用者停止之前和发布容器停止事件之前阻止方法的最长时间（以毫秒为单位）。`stop()`Spring中文文档
`stopContainerWhenFenced`Spring中文文档	`false`Spring中文文档	如果抛出，请停止侦听器容器。有关详细信息，请参阅回滚后处理器。`ProducerFencedException`Spring中文文档
`stopImmediate`Spring中文文档	`false`Spring中文文档	当容器停止时，请在当前记录之后停止处理，而不是在处理上一个轮询中的所有记录之后停止处理。Spring中文文档
`subBatchPerPartition`Spring中文文档	请参见 desc.Spring中文文档	使用批处理侦听器时，如果是，则调用侦听器，并将轮询结果拆分为子批处理，每个分区一个子批处理。违约。`truefalse`Spring中文文档
`syncCommitTimeout`Spring中文文档	`null`Spring中文文档	使用 when 的超时时间为。如果未设置，容器将尝试确定使用者属性并使用它;否则将使用 60 秒。`syncCommitstruedefault.api.timeout.ms`Spring中文文档
`syncCommits`Spring中文文档	`true`Spring中文文档	是否使用同步或异步提交进行偏移;看。`commitCallback`Spring中文文档
`主题主题模式主题分区`Spring中文文档	不适用Spring中文文档	配置的主题、主题模式或显式分配的主题/分区。互斥;必须至少提供一份;由构造函数强制执行。`ContainerProperties`Spring中文文档
`transactionManager`Spring中文文档	`null`Spring中文文档	自 3.2 起不推荐使用，请参见 [kafkaAwareTransactionManager]，其他事务管理器。Spring中文文档

表 2. 性能`AbstractListenerContainer`
财产	违约	描述
`afterRollbackProcessor`Spring中文文档	`DefaultAfterRollbackProcessor`Spring中文文档	在事务回滚后调用的 An 。`AfterRollbackProcessor`Spring中文文档
`applicationEventPublisher`Spring中文文档	应用程序上下文Spring中文文档	事件发布者。Spring中文文档
`batchErrorHandler`Spring中文文档	请参见 desc.Spring中文文档	已弃用 - 请参阅。`commonErrorHandler`Spring中文文档
`batchInterceptor`Spring中文文档	`null`Spring中文文档	在调用批处理侦听器之前将 a 设置为调用;不适用于录音侦听器。另请参见。`BatchInterceptorinterceptBeforeTx`Spring中文文档
`beanName`Spring中文文档	Bean 名称Spring中文文档	容器的 Bean 名称;后缀为 for 子容器。`-n`Spring中文文档
`commonErrorHandler`Spring中文文档	请参见 desc.Spring中文文档	`DefaultErrorHandler`或者当使用 A 时提供 A。请参阅容器错误处理程序。`nulltransactionManagerDefaultAfterRollbackProcessor`Spring中文文档
`containerProperties`Spring中文文档	`ContainerProperties`Spring中文文档	容器属性实例。Spring中文文档
`groupId`Spring中文文档	请参见 desc.Spring中文文档	如果存在，则为消费品工厂的属性。`containerProperties.groupIdgroup.id`Spring中文文档
`interceptBeforeTx`Spring中文文档	`true`Spring中文文档	确定是在事务开始之前还是之后调用。`recordInterceptor`Spring中文文档
`listenerId`Spring中文文档	请参见 desc.Spring中文文档	用户配置容器的 Bean 名称或 s 的属性。`id@KafkaListener`Spring中文文档
`listenerInfo`Spring中文文档	零Spring中文文档	要在标头中填充的值。对于，此值是从属性中获取的。此标头可以在各种位置使用，例如，以及侦听器代码本身。`KafkaHeaders.LISTENER_INFO@KafkaListenerinfoRecordInterceptorRecordFilterStrategy`Spring中文文档
`pauseRequested`Spring中文文档	（只读）Spring中文文档	如果已请求使用者暂停，则为 True。Spring中文文档
`recordInterceptor`Spring中文文档	`null`Spring中文文档	在调用记录侦听器之前设置 a to call;不适用于批处理侦听器。另请参见。`RecordInterceptorinterceptBeforeTx`Spring中文文档
`topicCheckTimeout`Spring中文文档	30年代Spring中文文档	当容器属性为时，操作完成的等待时间（以秒为单位）。`missingTopicsFataltruedescribeTopics`Spring中文文档

表 3. 性能`KafkaMessageListenerContainer`
财产	违约	描述
`assignedPartitions`Spring中文文档	（只读）Spring中文文档	当前分配给此容器的分区（显式或未显式）。Spring中文文档
`assignedPartitionsByClientId`Spring中文文档	（只读）Spring中文文档	当前分配给此容器的分区（显式或未显式）。Spring中文文档
`clientIdSuffix`Spring中文文档	`null`Spring中文文档	由并发容器用于为每个子容器的使用者提供唯一的 .`client.id`Spring中文文档
`containerPaused`Spring中文文档	不适用Spring中文文档	如果已请求暂停，并且使用者实际上已暂停，则为 true。Spring中文文档

表 4. 性能`ConcurrentMessageListenerContainer`
财产	违约	描述
`alwaysClientIdSuffix`Spring中文文档	`true`Spring中文文档	设置为 false 可禁止在仅为 1 时向 consumer 属性添加后缀。`client.idconcurrency`Spring中文文档
`assignedPartitions`Spring中文文档	（只读）Spring中文文档	当前分配给此容器的子 s（显式或未显式）的分区的聚合。`KafkaMessageListenerContainer`Spring中文文档
`assignedPartitionsByClientId`Spring中文文档	（只读）Spring中文文档	当前分配给此容器的子容器的分区（显式或不显式），由子容器的使用者属性键控。`KafkaMessageListenerContainerclient.id`Spring中文文档
`concurrency`Spring中文文档	1Spring中文文档	要管理的子项数。`KafkaMessageListenerContainer`Spring中文文档
`containerPaused`Spring中文文档	不适用Spring中文文档	如果已请求暂停，并且所有子容器的使用者实际上都已暂停，则为 true。Spring中文文档
`containers`Spring中文文档	不适用Spring中文文档	对所有子项的引用。`KafkaMessageListenerContainer`Spring中文文档