W3Cschool
恭喜您成為首批注冊(cè)用戶
獲得88經(jīng)驗(yàn)值獎(jiǎng)勵(lì)
以下屬性在活頁夾級(jí)別可用,并且必須以spring.cloud.stream.kafka.streams.binder.
文字作為前綴。
spring.cloud.stream.kafka.streams.binder.
為前綴。以下是使用此屬性的一些示例。spring.cloud.stream.kafka.streams.binder.configuration.default.key.serde=org.apache.kafka.common.serialization.Serdes$StringSerde spring.cloud.stream.kafka.streams.binder.configuration.default.value.serde=org.apache.kafka.common.serialization.Serdes$StringSerde spring.cloud.stream.kafka.streams.binder.configuration.commit.interval.ms=1000
有關(guān)可能用于流配置的所有屬性的更多信息,請(qǐng)參見Apache Kafka Streams文檔中的StreamsConfig JavaDocs。
經(jīng)紀(jì)人網(wǎng)址
默認(rèn)值:localhost
Zookeeper網(wǎng)址
默認(rèn)值:localhost
反序列化錯(cuò)誤處理程序類型。可能的值為-logAndContinue
,logAndFail
或sendToDlq
默認(rèn)值:logAndFail
在綁定程序級(jí)別全局設(shè)置Kafka Streams應(yīng)用程序的application.id的簡(jiǎn)便方法。如果應(yīng)用程序包含多個(gè)StreamListener
方法,則應(yīng)在每個(gè)輸入綁定的綁定級(jí)別上設(shè)置application.id。
默認(rèn)值:none
以下屬性僅適用于Kafka Streams生產(chǎn)者,并且必須以spring.cloud.stream.kafka.streams.bindings.<binding name>.producer.
字面量為前綴。為方便起見,如果存在多個(gè)輸出綁定并且它們都需要一個(gè)公共值,則可以使用前綴spring.cloud.stream.kafka.streams.default.producer.
進(jìn)行配置。
要使用的密鑰序列
默認(rèn)值:none
。
使用價(jià)值服務(wù)
默認(rèn)值:none
。
標(biāo)志以啟用本機(jī)編碼
默認(rèn)值:false
。
以下屬性僅適用于Kafka Streams使用者,并且必須以spring.cloud.stream.kafka.streams.bindings.<binding name>.consumer.`literal.
For convenience, if there multiple input bindings and they all require a common value, that can be configured by using the prefix `spring.cloud.stream.kafka.streams.default.consumer.
為前綴。
設(shè)置每個(gè)輸入綁定的application.id。
默認(rèn)值:none
要使用的密鑰序列
默認(rèn)值:none
。
使用價(jià)值服務(wù)
默認(rèn)值:none
。
使用傳入的KTable類型實(shí)現(xiàn)狀態(tài)存儲(chǔ)
默認(rèn)值:none
。
標(biāo)志以啟用本機(jī)解碼
默認(rèn)值:false
。
DLQ主題名稱。
默認(rèn)值:none
。
Copyright©2021 w3cschool編程獅|閩ICP備15016281號(hào)-3|閩公網(wǎng)安備35020302033924號(hào)
違法和不良信息舉報(bào)電話:173-0602-2364|舉報(bào)郵箱:jubao@eeedong.com
掃描二維碼
下載編程獅App
編程獅公眾號(hào)
聯(lián)系方式:
更多建議: