ackCount spring-doc.cadn.net.cn
|
1spring-doc.cadn.net.cn |
提交待处理偏移量之前的记录数,当ackMode 是COUNT 或COUNT_TIME .spring-doc.cadn.net.cn |
adviceChain spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
一条Advice 对象(例如MethodInterceptor around 建议)包装消息侦听器,按顺序调用。spring-doc.cadn.net.cn |
ackMode spring-doc.cadn.net.cn
|
Batchspring-doc.cadn.net.cn |
控制 offset 的提交频率 - 请参阅 Committing Offsets。spring-doc.cadn.net.cn |
ackTime spring-doc.cadn.net.cn
|
5000spring-doc.cadn.net.cn |
在ackMode 是TIME 或COUNT_TIME .spring-doc.cadn.net.cn |
assignmentCommitOption spring-doc.cadn.net.cn
|
LATEST_ONLY _NO_TXspring-doc.cadn.net.cn |
是否在分配时提交初始位置;默认情况下,仅当ConsumerConfig.AUTO_OFFSET_RESET_CONFIG 是latest 即使存在事务管理器,它也不会在事务中运行。
请参阅 JavaDocs 以获取ContainerProperties.AssignmentCommitOption 了解有关可用选项的更多信息。spring-doc.cadn.net.cn |
asyncAcks spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
启用无序提交(请参阅 手动提交偏移量);使用者将暂停,提交将延迟,直到填补间隙。spring-doc.cadn.net.cn |
authExceptionRetryInterval spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
当不为 null 时,一个Duration 在 poll 之间休眠时,当AuthenticationException 或AuthorizationException 由 Kafka 客户端抛出。
当 null 时,此类异常被视为致命异常,容器将停止。spring-doc.cadn.net.cn |
batchRecoverAfterRollback spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
设置为true 要启用批量恢复,请参阅 After Rollback Processor。spring-doc.cadn.net.cn |
clientId spring-doc.cadn.net.cn
|
(空字符串)spring-doc.cadn.net.cn |
的client.id consumer 属性。
覆盖 Consumer Factoryclient.id 财产;在并发容器中,-n 将添加为每个使用者实例的后缀。spring-doc.cadn.net.cn |
checkDeserExWhenKeyNull spring-doc.cadn.net.cn
|
假spring-doc.cadn.net.cn |
设置为true 以始终检查DeserializationException 标头时,如果null key 已收到。
当使用者代码无法确定ErrorHandlingDeserializer 已配置,例如在使用 delegating deserializer 时。spring-doc.cadn.net.cn |
checkDeserExWhenValueNull spring-doc.cadn.net.cn
|
假spring-doc.cadn.net.cn |
设置为true 以始终检查DeserializationException 标头时,如果null value 已收到。
当使用者代码无法确定ErrorHandlingDeserializer 已配置,例如在使用 delegating deserializer 时。spring-doc.cadn.net.cn |
commitCallback spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
当存在且syncCommits 是false 提交完成后调用的回调。spring-doc.cadn.net.cn |
commitLogLevel spring-doc.cadn.net.cn
|
调试spring-doc.cadn.net.cn |
与提交偏移量相关的日志的日志记录级别。spring-doc.cadn.net.cn |
consumerRebalanceListener spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
再平衡侦听器;请参阅 重新平衡侦听器。spring-doc.cadn.net.cn |
commitRetries spring-doc.cadn.net.cn
|
3spring-doc.cadn.net.cn |
设置重试次数RetriableCommitFailedException 使用syncCommits 设置为 true。
默认 3 (总共 4 次尝试)。spring-doc.cadn.net.cn |
consumerStartTimeout spring-doc.cadn.net.cn
|
30 秒spring-doc.cadn.net.cn |
在记录错误之前等待使用者启动的时间;例如,如果您使用的 Task Executor 线程不足,则可能会发生这种情况。spring-doc.cadn.net.cn |
deliveryAttemptHeader spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
请参阅 Delivery Attempts 标头。spring-doc.cadn.net.cn |
eosMode spring-doc.cadn.net.cn
|
V2 spring-doc.cadn.net.cn
|
Exactly Once 语义模式;请参阅 Exactly Once 语义。spring-doc.cadn.net.cn |
fixTxOffsets spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
当使用事务创建者生成的记录时,如果使用者位于分区的末尾,则滞后可能会错误地报告为大于零,因为伪记录用于指示事务提交/回滚,并且可能存在回滚记录。
这在功能上不会影响消费者,但一些用户表示担心“滞后”不为零。
将此属性设置为true 容器将更正此类误报的偏移量。
该检查在下一次轮询之前执行,以避免增加提交处理的复杂性。
在撰写本文时,只有当消费者配置了isolation.level=read_committed 和max.poll.records 大于 1。
有关更多信息,请参阅 KAFKA-10683。spring-doc.cadn.net.cn |
groupId spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
覆盖使用者group.id 财产;由@KafkaListener id 或groupId 财产。spring-doc.cadn.net.cn |
idleBeforeDataMultiplier spring-doc.cadn.net.cn
|
5.0spring-doc.cadn.net.cn |
乘数idleEventInterval ,该 API 将在收到任何记录之前应用。
收到记录后,将不再应用乘数。
自 2.8 版起可用。spring-doc.cadn.net.cn |
idleBetweenPolls spring-doc.cadn.net.cn
|
0spring-doc.cadn.net.cn |
用于通过在轮询之间休眠线程来减慢投放速度。
处理一批记录的时间加上此值必须小于max.poll.interval.ms consumer 属性。spring-doc.cadn.net.cn |
idleEventInterval spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
设置后,将启用ListenerContainerIdleEvent s,请参阅 应用程序事件 和 检测空闲和无响应的使用者。
另请参阅idleBeforeDataMultiplier .spring-doc.cadn.net.cn |
idlePartitionEventInterval spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
设置后,将启用ListenerContainerIdlePartitionEvent s,请参阅 应用程序事件 和 检测空闲和无响应的使用者。spring-doc.cadn.net.cn |
kafkaConsumerProperties spring-doc.cadn.net.cn
|
没有spring-doc.cadn.net.cn |
用于覆盖在 Consumer Factory 上配置的任何任意 Consumer 属性。spring-doc.cadn.net.cn |
kafkaAwareTransactionManager spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
请参阅 事务。spring-doc.cadn.net.cn |
listenerTaskExecutor spring-doc.cadn.net.cn
|
SimpleAsyncTaskExecutor spring-doc.cadn.net.cn
|
用于运行使用者线程的任务执行程序。
默认执行程序会创建名为<name>-C-n ;使用KafkaMessageListenerContainer ,则 name 是 bean 名称;使用ConcurrentMessageListenerContainer 名称是后缀为-m 哪里m 对于每个子容器递增。请参阅容器线程命名。spring-doc.cadn.net.cn |
logContainerConfig spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
设置为true 在 INFO 级别记录所有容器属性。spring-doc.cadn.net.cn |
messageListener spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
消息侦听器。spring-doc.cadn.net.cn |
micrometerEnabled spring-doc.cadn.net.cn
|
true spring-doc.cadn.net.cn
|
是否维护使用者线程的 Micrometer 计时器。spring-doc.cadn.net.cn |
micrometerTags spring-doc.cadn.net.cn
|
空spring-doc.cadn.net.cn |
要添加到微米度量的静态标签的映射。spring-doc.cadn.net.cn |
micrometerTagsProvider spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
一个基于使用者记录提供动态标签的函数。spring-doc.cadn.net.cn |
missingTopicsFatal spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
如果代理上不存在配置的主题,则为 true 时将阻止容器启动。spring-doc.cadn.net.cn |
monitorInterval spring-doc.cadn.net.cn
|
30 秒spring-doc.cadn.net.cn |
检查使用者线程状态的频率NonResponsiveConsumerEvent s.
看noPollThreshold 和pollTimeout .spring-doc.cadn.net.cn |
noPollThreshold spring-doc.cadn.net.cn
|
3.0spring-doc.cadn.net.cn |
乘以pollTimeOut 要确定是否发布NonResponsiveConsumerEvent .
看monitorInterval .spring-doc.cadn.net.cn |
observationConvention spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
设置后,根据使用者记录中的信息向计时器和跟踪添加动态标记。spring-doc.cadn.net.cn |
observationEnabled spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
设置为true 启用通过 Micrometer 进行观察。spring-doc.cadn.net.cn |
offsetAndMetadataProvider spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
一个OffsetAndMetadata ;默认情况下,提供程序会创建具有空元数据的偏移量和元数据。提供程序提供了一种自定义元数据的方法。spring-doc.cadn.net.cn |
onlyLogRecordMetadata spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
设置为false 记录完整的使用者记录(错误、调试日志等),而不仅仅是topic-partition@offset .spring-doc.cadn.net.cn |
pauseImmediate spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
当容器暂停时,在当前记录之后停止处理,而不是在处理上一次轮询的所有记录之后停止处理;其余记录保留在内存中,并将在容器恢复时传递给侦听器。spring-doc.cadn.net.cn |
pollTimeout spring-doc.cadn.net.cn
|
5000spring-doc.cadn.net.cn |
传入的超时Consumer.poll() 以毫秒为单位。spring-doc.cadn.net.cn |
pollTimeoutWhilePaused spring-doc.cadn.net.cn
|
100spring-doc.cadn.net.cn |
传入的超时Consumer.poll() (以毫秒为单位)当容器处于暂停状态时。spring-doc.cadn.net.cn |
restartAfterAuthExceptions spring-doc.cadn.net.cn
|
假spring-doc.cadn.net.cn |
如果容器因授权/身份验证异常而停止,则为 True,则重新启动容器。spring-doc.cadn.net.cn |
scheduler spring-doc.cadn.net.cn
|
ThreadPoolTaskScheduler spring-doc.cadn.net.cn
|
要在其上运行使用者监视器任务的计划程序。spring-doc.cadn.net.cn |
shutdownTimeout spring-doc.cadn.net.cn
|
10000spring-doc.cadn.net.cn |
阻止stop() 方法,直到所有使用者停止,并在发布容器停止事件之前。spring-doc.cadn.net.cn |
stopContainerWhenFenced spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
如果ProducerFencedException 被抛出。
有关更多信息,请参阅 After-rollback Processor 。spring-doc.cadn.net.cn |
stopImmediate spring-doc.cadn.net.cn
|
false spring-doc.cadn.net.cn
|
当容器停止时,请在当前记录之后停止处理,而不是在处理上一次轮询的所有记录之后停止处理。spring-doc.cadn.net.cn |
subBatchPerPartition spring-doc.cadn.net.cn
|
见 desc.spring-doc.cadn.net.cn |
使用批处理侦听器时,如果这是true ,则调用侦听器时,轮询结果将拆分为子批处理,每个分区一个子批处理。
违约false .spring-doc.cadn.net.cn |
syncCommitTimeout spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
在以下情况下使用的超时syncCommits 是true .
如果未设置,容器将尝试确定default.api.timeout.ms 消费者财产并使用它;否则将使用 60 秒。spring-doc.cadn.net.cn |
syncCommits spring-doc.cadn.net.cn
|
true spring-doc.cadn.net.cn
|
是否对偏移量使用 sync 或 async commits;看commitCallback .spring-doc.cadn.net.cn |
topics topicPattern topicPartitions spring-doc.cadn.net.cn
|
不适用spring-doc.cadn.net.cn |
配置的主题、主题模式或显式分配的主题/分区。
互斥;必须至少提供一个;强制执行者ContainerProperties 构造 函数。spring-doc.cadn.net.cn |
transactionManager spring-doc.cadn.net.cn
|
null spring-doc.cadn.net.cn
|
自 3.2 起已移除,请参阅 [kafkaAwareTransactionManager], 其他事务管理器。spring-doc.cadn.net.cn |