ackCountspring-doc.cadn.net.cn
|
1spring-doc.cadn.net.cn |
提交待处理偏移量之前的记录数，当ackMode是COUNT或COUNT_TIME.spring-doc.cadn.net.cn |
adviceChainspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
一条链Advice对象（例如MethodInterceptor围绕建议）包装消息侦听器，按顺序调用。spring-doc.cadn.net.cn |
ackModespring-doc.cadn.net.cn
|
Batchspring-doc.cadn.net.cn |
控制偏移量的提交频率 - 请参阅提交偏移量。spring-doc.cadn.net.cn |
ackTimespring-doc.cadn.net.cn
|
5000spring-doc.cadn.net.cn |
在ackMode是TIME或COUNT_TIME.spring-doc.cadn.net.cn |
assignmentCommitOptionspring-doc.cadn.net.cn
|
LATEST_ONLY _NO_TXspring-doc.cadn.net.cn |
是否承诺分配的初始职位;默认情况下，只有在ConsumerConfig.AUTO_OFFSET_RESET_CONFIG是latest即使存在事务管理器，它也不会在事务中运行。
请参阅 JavaDocsContainerProperties.AssignmentCommitOption有关可用选项的更多信息。spring-doc.cadn.net.cn |
asyncAcksspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
启用无序提交（请参阅手动提交偏移量）;使用者将暂停，提交将被推迟，直到填补空白。spring-doc.cadn.net.cn |
authExceptionRetryIntervalspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
如果不是空，则Duration在轮投票之间休眠AuthenticationException或AuthorizationException由 Kafka 客户端抛出。
当 null 时，此类异常被视为致命异常，容器将停止。spring-doc.cadn.net.cn |
batchRecoverAfterRollbackspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为true要启用批量恢复，请参阅回滚处理器后。spring-doc.cadn.net.cn |
clientIdspring-doc.cadn.net.cn
|
（空字符串）spring-doc.cadn.net.cn |
的前缀client.id消费者财产。
覆盖消费者工厂client.id财产;在并发容器中，-n作为每个消费者实例的后缀添加。spring-doc.cadn.net.cn |
checkDeserExWhenKeyNullspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn |
设置为true始终检查DeserializationException标头，当null key收到。
当消费者代码无法确定ErrorHandlingDeserializer已配置，例如在使用委托反序列化程序时。spring-doc.cadn.net.cn |
checkDeserExWhenValueNullspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn |
设置为true始终检查DeserializationException标头，当null value收到。
当消费者代码无法确定ErrorHandlingDeserializer已配置，例如在使用委托反序列化程序时。spring-doc.cadn.net.cn |
commitCallbackspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
当存在时和syncCommits是false提交完成后调用的回调。spring-doc.cadn.net.cn |
commitLogLevelspring-doc.cadn.net.cn
|
调试spring-doc.cadn.net.cn |
与提交偏移量相关的日志的日志记录级别。spring-doc.cadn.net.cn |
consumerRebalanceListenerspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
重新平衡侦听器;请参阅重新平衡侦听器。spring-doc.cadn.net.cn |
commitRetriesspring-doc.cadn.net.cn
|
3spring-doc.cadn.net.cn |
设置重试次数RetriableCommitFailedException使用时syncCommits设置为 true。默认值为 3（总共 4 次尝试）。spring-doc.cadn.net.cn |
consumerStartTimeoutspring-doc.cadn.net.cn
|
30多岁spring-doc.cadn.net.cn |
在记录错误之前等待使用者启动的时间;例如，如果您使用线程不足的任务执行器，则可能会发生这种情况。spring-doc.cadn.net.cn |
deliveryAttemptHeaderspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
请参阅 Delivery Attempts 标头。spring-doc.cadn.net.cn |
eosModespring-doc.cadn.net.cn
|
V2spring-doc.cadn.net.cn
|
“恰好一次语义”模式;请参阅“恰好一次语义”。spring-doc.cadn.net.cn |
fixTxOffsetsspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
当使用事务生产者生成的记录时，并且使用者位于分区的末尾，由于用于指示事务提交/回滚的伪记录，并且可能存在回滚记录，因此延迟可能会被错误地报告为大于零。这在功能上不会影响使用者，但一些用户表示担心“滞后”不是零。将此属性设置为true并且容器将纠正此类错误报告的偏移量。在下一次轮询之前执行检查，以避免给提交处理增加显着的复杂性。在撰写本文时，只有当消费者配置了isolation.level=read_committed和max.poll.records大于 1。有关更多信息，请参阅 KAFKA-10683。spring-doc.cadn.net.cn |
groupIdspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
覆盖消费者group.id财产; 由@KafkaListener id或groupId财产。spring-doc.cadn.net.cn |
idleBeforeDataMultiplierspring-doc.cadn.net.cn
|
5.0spring-doc.cadn.net.cn |
乘数idleEventInterval在收到任何记录之前应用。收到记录后，不再应用乘数。从 2.8 版开始可用。spring-doc.cadn.net.cn |
idleBetweenPollsspring-doc.cadn.net.cn
|
0spring-doc.cadn.net.cn |
用于通过在轮询之间休眠线程来减慢交付速度。处理一批记录的时间加上此值必须小于max.poll.interval.ms消费者财产。spring-doc.cadn.net.cn |
idleEventIntervalspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
设置后，启用发布ListenerContainerIdleEvents，请参阅应用程序事件和检测空闲和无响应的使用者。另请参阅idleBeforeDataMultiplier.spring-doc.cadn.net.cn |
idlePartitionEventIntervalspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
设置后，启用发布ListenerContainerIdlePartitionEvents，请参阅应用程序事件和检测空闲和无响应使用者。spring-doc.cadn.net.cn |
kafkaConsumerPropertiesspring-doc.cadn.net.cn
|
没有spring-doc.cadn.net.cn |
用于覆盖在消费者工厂上配置的任何任意消费者属性。spring-doc.cadn.net.cn |
kafkaAwareTransactionManagerspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
请参阅事务。spring-doc.cadn.net.cn |
listenerTaskExecutorspring-doc.cadn.net.cn
|
SimpleAsyncTaskExecutorspring-doc.cadn.net.cn
|
用于运行使用者线程的任务执行器。默认执行器创建名为<name>-C-n;使用KafkaMessageListenerContainer，名称是 bean 名称;使用ConcurrentMessageListenerContainer名称是后缀为-m哪里m为每个子容器递增。请参阅容器线程命名。spring-doc.cadn.net.cn |
logContainerConfigspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为true在 INFO 级别记录所有容器属性。spring-doc.cadn.net.cn |
messageListenerspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
消息侦听器。spring-doc.cadn.net.cn |
micrometerEnabledspring-doc.cadn.net.cn
|
truespring-doc.cadn.net.cn
|
是否为使用者线程维护千分尺计时器。spring-doc.cadn.net.cn |
micrometerTagsspring-doc.cadn.net.cn
|
emptyspring-doc.cadn.net.cn |
要添加到微米指标的静态标记的映射。spring-doc.cadn.net.cn |
micrometerTagsProviderspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
基于使用者记录提供动态标记的函数。spring-doc.cadn.net.cn |
missingTopicsFatalspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
如果配置的主题不存在于代理上，则为 true 将阻止容器启动。spring-doc.cadn.net.cn |
monitorIntervalspring-doc.cadn.net.cn
|
30多岁spring-doc.cadn.net.cn |
检查使用者线程状态的频率NonResponsiveConsumerEvents.
看noPollThreshold和pollTimeout.spring-doc.cadn.net.cn |
noPollThresholdspring-doc.cadn.net.cn
|
3.0spring-doc.cadn.net.cn |
乘以pollTimeOut以确定是否发布NonResponsiveConsumerEvent.
看monitorInterval.spring-doc.cadn.net.cn |
observationConventionspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
设置后，根据使用者记录中的信息向计时器和跟踪添加动态标记。spring-doc.cadn.net.cn |
observationEnabledspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为true通过千分尺进行观察。spring-doc.cadn.net.cn |
offsetAndMetadataProviderspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
的提供程序OffsetAndMetadata;默认情况下，提供程序会创建偏移量和元数据，其中包含空元数据。提供程序提供了一种自定义元数据的方法。spring-doc.cadn.net.cn |
onlyLogRecordMetadataspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为false记录完整的使用者记录（错误、调试日志等），而不仅仅是topic-partition@offset.spring-doc.cadn.net.cn |
pauseImmediatespring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
当容器暂停时，在当前记录之后停止处理，而不是在处理上一次轮询中的所有记录之后停止处理;其余记录保留在内存中，并在容器恢复时传递给侦听器。spring-doc.cadn.net.cn |
pollTimeoutspring-doc.cadn.net.cn
|
5000spring-doc.cadn.net.cn |
超时传递到Consumer.poll()以毫秒为单位。spring-doc.cadn.net.cn |
pollTimeoutWhilePausedspring-doc.cadn.net.cn
|
100spring-doc.cadn.net.cn |
超时传递到Consumer.poll()（以毫秒为单位）当容器处于暂停状态时。spring-doc.cadn.net.cn |
restartAfterAuthExceptionsspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn |
True 表示在容器因授权/身份验证异常而停止时重新启动容器。spring-doc.cadn.net.cn |
schedulerspring-doc.cadn.net.cn
|
ThreadPoolTaskSchedulerspring-doc.cadn.net.cn
|
用于运行使用者监视任务的调度程序。spring-doc.cadn.net.cn |
shutdownTimeoutspring-doc.cadn.net.cn
|
10000spring-doc.cadn.net.cn |
阻止stop()方法，直到所有使用者停止，并在发布容器停止事件之前。spring-doc.cadn.net.cn |
stopContainerWhenFencedspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
如果出现以下情况，请停止侦听器容器ProducerFencedException被抛出。
有关详细信息，请参阅回滚后处理器。spring-doc.cadn.net.cn |
stopImmediatespring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
当容器停止时，在当前记录之后停止处理，而不是在处理上一次轮询中的所有记录之后停止处理。spring-doc.cadn.net.cn |
subBatchPerPartitionspring-doc.cadn.net.cn
|
参见描述。spring-doc.cadn.net.cn |
使用批处理侦听器时，如果这是true，则调用侦听器，轮询结果拆分为子批次，每个分区一个。
违约false.spring-doc.cadn.net.cn |
syncCommitTimeoutspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
在以下情况下使用的超时syncCommits是true.
如果未设置，容器将尝试确定default.api.timeout.ms消费者财产并使用它;否则将使用 60 秒。spring-doc.cadn.net.cn |
syncCommitsspring-doc.cadn.net.cn
|
truespring-doc.cadn.net.cn
|
是否使用同步或异步提交进行偏移;看commitCallback.spring-doc.cadn.net.cn |
topics topicPattern topicPartitionsspring-doc.cadn.net.cn
|
不适用spring-doc.cadn.net.cn |
配置的主题、主题模式或显式分配的主题/分区。
互斥;必须至少提供一个;强制执行者ContainerProperties构造 函数。spring-doc.cadn.net.cn |
transactionManagerspring-doc.cadn.net.cn
|
nullspring-doc.cadn.net.cn
|
自 3.2 起已弃用，请参阅 [kafkaAwareTransactionManager]，其他事务管理器。spring-doc.cadn.net.cn |