SpringCloud Kafka Binder Properties

2023-11-28 16:19 更新
spring.cloud.stream.kafka.binder.brokers

Kafka活頁夾所連接的代理列表。

默認(rèn)值:localhost。

spring.cloud.stream.kafka.binder.defaultBrokerPort

brokers允許指定帶有或不帶有端口信息的主機(例如,host1,host2:port2)。當(dāng)代理列表中未配置任何端口時,這將設(shè)置默認(rèn)端口。

默認(rèn)值:9092

spring.cloud.stream.kafka.binder.configuration

客戶端屬性(生產(chǎn)者和消費者)的鍵/值映射傳遞給綁定程序創(chuàng)建的所有客戶端。由于生產(chǎn)者和消費者都使用了這些屬性,因此應(yīng)將使用限制為通用屬性,例如安全性設(shè)置。Properties在這里取代引導(dǎo)中設(shè)置的所有屬性。

默認(rèn)值:空地圖。

spring.cloud.stream.kafka.binder.consumerProperties

任意Kafka客戶端使用者屬性的鍵/值映射。這里的Properties取代了啟動時和上面的configuration屬性中設(shè)置的所有屬性。

默認(rèn)值:空地圖。

spring.cloud.stream.kafka.binder.headers

活頁夾傳輸?shù)淖远x標(biāo)頭列表。僅當(dāng)與kafka-clients版本<0.11.0.0的舊版應(yīng)用程序(?1.3.x)通信時才需要。較新的版本本機支持標(biāo)頭。

默認(rèn)值:空。

spring.cloud.stream.kafka.binder.healthTimeout

等待獲取分區(qū)信息的時間,以秒為單位。如果此計時器到期,運行狀況將報告為已關(guān)閉。

默認(rèn)值:10

spring.cloud.stream.kafka.binder.requiredAcks

代理程序上所需的確認(rèn)數(shù)。有關(guān)生產(chǎn)者acks屬性的信息,請參見Kafka文檔。

默認(rèn)值:1。

spring.cloud.stream.kafka.binder.minPartitionCount

僅在設(shè)置了autoCreateTopicsautoAddPartitions時有效。活頁夾在生成或使用數(shù)據(jù)的主題上配置的全局最小分區(qū)數(shù)。可以通過生產(chǎn)者的partitionCount設(shè)置或生產(chǎn)者的instanceCount * concurrency設(shè)置的值(如果任一個較大)來代替它。

默認(rèn)值:1。

spring.cloud.stream.kafka.binder.producer屬性

任意Kafka客戶端生產(chǎn)者屬性的鍵/值映射。這里的Properties取代了啟動時和上面的configuration屬性中設(shè)置的所有屬性。

默認(rèn)值:空地圖。

spring.cloud.stream.kafka.binder.replicationFactor

如果autoCreateTopics有效,則自動創(chuàng)建的主題的復(fù)制因子。可以在每個綁定上覆蓋。

默認(rèn)值:1。

spring.cloud.stream.kafka.binder.autoCreateTopics

如果設(shè)置為true,則活頁夾將自動創(chuàng)建新主題。如果設(shè)置為false,則活頁夾依賴于已配置的主題。在后一種情況下,如果主題不存在,則活頁夾無法啟動。

默認(rèn)值:true。

 此設(shè)置與代理的auto.topic.create.enable設(shè)置無關(guān),并且不影響它。如果服務(wù)器設(shè)置為自動創(chuàng)建主題,則可以使用默認(rèn)代理設(shè)置將它們作為元數(shù)據(jù)檢索請求的一部分進行創(chuàng)建。

spring.cloud.stream.kafka.binder.autoAddPartitions

如果設(shè)置為true,則活頁夾將根據(jù)需要創(chuàng)建新分區(qū)。如果設(shè)置為false,則活頁夾依賴于已配置的主題的分區(qū)大小。如果目標(biāo)主題的分區(qū)數(shù)小于預(yù)期值,則活頁夾無法啟動。

默認(rèn)值:false。

spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix

在活頁夾中啟用事務(wù)。請參閱Kafka文檔中的transaction.idspring-kafka文檔中的Transactions啟用事務(wù)后,將忽略各個producer屬性,并且所有生產(chǎn)者都將使用spring.cloud.stream.kafka.binder.transaction.producer.*屬性。

默認(rèn)值null(無交易)

spring.cloud.stream.kafka.binder.transaction.producer。*

交易綁定中生產(chǎn)者的全球生產(chǎn)者屬性。請參見spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix“ Kafka生產(chǎn)者Properties”以及所有活頁夾支持的常規(guī)生產(chǎn)者屬性。

默認(rèn)值:請參見各個生產(chǎn)者屬性。

spring.cloud.stream.kafka.binder.headerMapperBeanName

KafkaHeaderMapper的bean名稱,用于將spring-messaging標(biāo)頭映射到Kafka標(biāo)頭和從Kafka標(biāo)頭映射。例如,如果您希望自定義在標(biāo)頭中使用JSON反序列化的DefaultKafkaHeaderMapper中的受信任軟件包,請使用此方法。

默認(rèn)值:無。


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

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號