ackCountspring-doc.cadn.net.cn
|
1spring-doc.cadn.net.cn |
在提交待处理偏移量之前的记录数ack模式是计数或COUNT_TIME.spring-doc.cadn.net.cn |
建议链spring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
一条链建议对象（例如：拦截方法围绕建议）包裹消息，按顺序调用。spring-doc.cadn.net.cn |
ack模式spring-doc.cadn.net.cn
|
Batchspring-doc.cadn.net.cn |
控制提交偏移的频率——参见提交偏移量。spring-doc.cadn.net.cn |
ackTimespring-doc.cadn.net.cn
|
5000spring-doc.cadn.net.cn |
当ack模式是时间或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是最近的即使有事务管理器，它也不会在事务中运行。
请参见 JavaDocsContainerProperties.AssignmentCommitOption有关可用选项的更多信息。spring-doc.cadn.net.cn |
异步加速spring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
启用乱序提交（参见手动提交偏移）;消费者会被暂停，提交会被推迟，直到填补空隙。spring-doc.cadn.net.cn |
authExceptionRetryIntervalspring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
当不是零时，a期间当认证异常或授权例外被卡夫卡客户端抛出。
当异常为零时，此类异常被视为致命，容器将停止。spring-doc.cadn.net.cn |
批量恢复回滚后spring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为true要启用批处理恢复，请参见回滚处理器之后。spring-doc.cadn.net.cn |
客户标识spring-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总是要检查反序列化例外当 a 时零 钥匙收到了。
当消费者代码无法确定ErrorHandlingDeserializer已经配置过，比如在使用委派解串器时。spring-doc.cadn.net.cn |
checkDeserExWhenValueNullspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn |
设置为true总是要检查反序列化例外当 a 时零 值收到了。
当消费者代码无法确定ErrorHandlingDeserializer已经配置过，比如在使用委派解串器时。spring-doc.cadn.net.cn |
提交回调spring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
当存在时同步提交是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
|
零spring-doc.cadn.net.cn
|
一个重新平衡的倾听者;参见“重新平衡听众”。spring-doc.cadn.net.cn |
commitRetriesspring-doc.cadn.net.cn
|
3spring-doc.cadn.net.cn |
设置重试次数RetriableCommitFailedException使用同步提交设置为 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
|
请参见投递尝试标题。spring-doc.cadn.net.cn |
eos模式spring-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 |
组IDspring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
覆盖消费者group.id财产;由@KafkaListener 身份证或组ID财产。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
|
零spring-doc.cadn.net.cn
|
设置时，能够发布ListenerContainerIdleEvent参见应用事件和检测空闲和无响应消费者。
另见idleBeforeDataMultiplier.spring-doc.cadn.net.cn |
idlePartitionEventIntervalspring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
设置时，能够发布ListenerContainerIdlePartitionEvent参见应用事件和检测空闲和无响应消费者。spring-doc.cadn.net.cn |
kafka消费者属性spring-doc.cadn.net.cn
|
没有spring-doc.cadn.net.cn |
用于覆盖消费工厂上任意配置的消费者属性。spring-doc.cadn.net.cn |
kafkaAwareTransactionManagerspring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
参见交易。spring-doc.cadn.net.cn |
listenerTaskExecutorspring-doc.cadn.net.cn
|
SimpleAsyncTaskExecutorspring-doc.cadn.net.cn
|
一个任务执行器用于运行消费者线程。
默认执行程序创建名为<名字>C-n;其中KafkaMessageListenerContainer，这个名字就是豆子的名字;其中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 |
消息听众spring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
信息倾听者。spring-doc.cadn.net.cn |
MicroEnabledspring-doc.cadn.net.cn
|
truespring-doc.cadn.net.cn
|
是否要为消费线维护微米定时器。spring-doc.cadn.net.cn |
微米标签spring-doc.cadn.net.cn
|
emptyspring-doc.cadn.net.cn |
一张静态标签的地图，将添加到微米级公制中。spring-doc.cadn.net.cn |
微米标签提供者spring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
一个基于消费者记录提供动态标签的功能。spring-doc.cadn.net.cn |
缺失主题致命spring-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和投票时间.spring-doc.cadn.net.cn |
noPollThresholdspring-doc.cadn.net.cn
|
3.0spring-doc.cadn.net.cn |
乘以pollTimeOut以决定是否发布NonResponsiveConsumerEvent.
看monitorInterval.spring-doc.cadn.net.cn |
观察大会spring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
设置好后，根据消费者记录中的信息，在定时器和追踪中添加动态标签。spring-doc.cadn.net.cn |
观察启用spring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为true以便通过微米观察。spring-doc.cadn.net.cn |
offsetAndMetadataProviderspring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
一个提供者偏移量与元数据;默认情况下，提供者创建一个偏移量和带有空元数据的元数据。提供者提供了自定义元数据的方法。spring-doc.cadn.net.cn |
仅有LogRecord元数据spring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
设置为false记录完整的消费者记录（错误记录、调试日志等），而不仅仅是话题partition@offset.spring-doc.cadn.net.cn |
暂停立刻spring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
当容器暂停时，应在当前记录结束后停止处理，而不是在处理完上一次轮询的所有记录后;剩余的记录会被保留在内存中，并在容器恢复时传递给监听者。spring-doc.cadn.net.cn |
投票时间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 |
restartAfterAuthExceptionsspring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn |
如果容器因授权/认证异常被停止，重启是正确的。spring-doc.cadn.net.cn |
调度spring-doc.cadn.net.cn
|
ThreadPoolTaskSchedulerspring-doc.cadn.net.cn
|
一个用于运行消费者监控任务的调度器。spring-doc.cadn.net.cn |
停机 Timeoutspring-doc.cadn.net.cn
|
10000spring-doc.cadn.net.cn |
阻断停止（）方法直到所有消费者停止且在发布容器停止事件之前。spring-doc.cadn.net.cn |
停止容器围栏spring-doc.cadn.net.cn
|
falsespring-doc.cadn.net.cn
|
如果是制片人受限例外被抛出。
更多信息请参见后回滚处理器。spring-doc.cadn.net.cn |
立即停止spring-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 |
同步提交时间spring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
超时时间同步提交是true.
当未设置时，容器将尝试确定default.api.timeout.ms消费品并加以利用;否则将耗时60秒。spring-doc.cadn.net.cn |
同步提交spring-doc.cadn.net.cn
|
truespring-doc.cadn.net.cn
|
偏移量是使用同步还是异步提交;看提交回调.spring-doc.cadn.net.cn |
主题 主题模式 主题分区spring-doc.cadn.net.cn
|
无spring-doc.cadn.net.cn |
配置的主题、主题模式或明确分配的主题/分区。
互斥;至少必须提供一个;执行容器属性构造 函数。spring-doc.cadn.net.cn |
transactionManagerspring-doc.cadn.net.cn
|
零spring-doc.cadn.net.cn
|
自3.2版本起已弃用，参见[kafkaAwareTransactionManager]，其他事务管理器。spring-doc.cadn.net.cn |