SpringCloud Kafka流Properties

2023-11-29 15:20 更新

以下屬性在活頁夾級(jí)別可用,并且必須以spring.cloud.stream.kafka.streams.binder.文字作為前綴。

組態(tài)
使用包含與Apache Kafka Streams API有關(guān)的屬性的鍵/值對(duì)進(jìn)行映射。此屬性必須以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ì)人

經(jīng)紀(jì)人網(wǎng)址

默認(rèn)值:localhost

zkNodes

Zookeeper網(wǎng)址

默認(rèn)值:localhost

serdeError

反序列化錯(cuò)誤處理程序類型。可能的值為-logAndContinue,logAndFailsendToDlq

默認(rèn)值:logAndFail

applicationId

在綁定程序級(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

valueSerde

使用價(jià)值服務(wù)

默認(rèn)值:none。

useNativeEncoding

標(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.為前綴。

applicationId

設(shè)置每個(gè)輸入綁定的application.id。

默認(rèn)值:none

鑰匙串

要使用的密鑰序列

默認(rèn)值:none。

valueSerde

使用價(jià)值服務(wù)

默認(rèn)值:none

物化為

使用傳入的KTable類型實(shí)現(xiàn)狀態(tài)存儲(chǔ)

默認(rèn)值:none。

useNativeDecoding

標(biāo)志以啟用本機(jī)解碼

默認(rèn)值:false

dlqName

DLQ主題名稱。

默認(rèn)值:none

以上內(nèi)容是否對(duì)您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)