SpringCloud 消費(fèi)者Properties

入站使用者的并發(fā)。

默認(rèn)值：1。

消費(fèi)者是否從分區(qū)生產(chǎn)者那里接收數(shù)據(jù)。

默認(rèn)值：false。

設(shè)置為none時(shí)，禁用輸入的標(biāo)頭解析。僅對本身不支持消息頭并且需要消息頭嵌入的消息中間件有效。當(dāng)不支持本機(jī)頭時(shí)，使用來自非Spring Cloud Stream應(yīng)用程序的數(shù)據(jù)時(shí)，此選項(xiàng)很有用。設(shè)置為headers時(shí)，它使用中間件的本機(jī)頭機(jī)制。設(shè)置為embeddedHeaders時(shí)，它將標(biāo)頭嵌入到消息有效負(fù)載中。

默認(rèn)值：取決于活頁夾的實(shí)現(xiàn)。

如果處理失敗，則嘗試處理消息的次數(shù)（包括第一次）。設(shè)置為1以禁用重試。

默認(rèn)值：3。

重試時(shí)的退避初始間隔。

默認(rèn)值：1000。

最大退避間隔。

默認(rèn)值：10000。

退避乘數(shù)。

默認(rèn)值：2.0。

retryableExceptions中未列出的由偵聽器引發(fā)的異常是否可以重試。

默認(rèn)值：true。

設(shè)置為大于零的值時(shí)，它允許自定義此使用者的實(shí)例索引（如果與spring.cloud.stream.instanceIndex不同）。設(shè)置為負(fù)值時(shí)，默認(rèn)為spring.cloud.stream.instanceIndex。有關(guān)更多信息，請參見“實(shí)例索引和實(shí)例計(jì)數(shù)” 。

默認(rèn)值：-1。

設(shè)置為大于零的值時(shí)，它允許自定義此使用者的實(shí)例計(jì)數(shù)（如果與spring.cloud.stream.instanceCount不同）。設(shè)置為負(fù)值時(shí)，默認(rèn)為spring.cloud.stream.instanceCount。有關(guān)更多信息，請參見“實(shí)例索引和實(shí)例計(jì)數(shù)” ”。

默認(rèn)值：-1。

鍵中Throwable類名稱的映射，值中布爾值的映射。指定將要重試的那些異常（和子類）。另請參見defaultRetriable。示例：spring.cloud.stream.bindings.input.consumer.retryable-exceptions.java.lang.IllegalStateException=false。

默認(rèn)值：空。

設(shè)置為true時(shí)，入站消息將直接由客戶端庫反序列化，該庫必須進(jìn)行相應(yīng)配置（例如，設(shè)置適當(dāng)?shù)腒afka生產(chǎn)者值反序列化器）。使用此配置時(shí)，入站消息解組不是基于綁定的contentType。使用本機(jī)解碼時(shí)，生產(chǎn)者負(fù)責(zé)使用適當(dāng)?shù)木幋a器（例如，Kafka生產(chǎn)者值序列化程序）對出站消息進(jìn)行序列化。同樣，當(dāng)使用本機(jī)編碼和解碼時(shí)，headerMode=embeddedHeaders屬性將被忽略，并且標(biāo)頭不會(huì)嵌入消息中。請參見生產(chǎn)者屬性useNativeEncoding。

默認(rèn)值：false。