SpringCloud Kafka Binder Properties
- spring.cloud.stream.kafka.binder.brokers
Kafka活页夹所连接的代理列表。
默认值:
localhost
。- spring.cloud.stream.kafka.binder.defaultBrokerPort
brokers
允许指定带有或不带有端口信息的主机(例如,host1,host2:port2
)。当代理列表中未配置任何端口时,这将设置默认端口。默认值:
9092
。- spring.cloud.stream.kafka.binder.configuration
客户端属性(生产者和消费者)的键/值映射传递给绑定程序创建的所有客户端。由于生产者和消费者都使用了这些属性,因此应将使用限制为通用属性,例如安全性设置。Properties在这里取代引导中设置的所有属性。
默认值:空地图。
- spring.cloud.stream.kafka.binder.consumerProperties
任意Kafka客户端使用者属性的键/值映射。这里的Properties取代了启动时和上面的
configuration
属性中设置的所有属性。默认值:空地图。
- spring.cloud.stream.kafka.binder.headers
活页夹传输的自定义标头列表。仅当与
kafka-clients
版本<0.11.0.0的旧版应用程序(⇐1.3.x)通信时才需要。较新的版本本机支持标头。默认值:空。
- spring.cloud.stream.kafka.binder.healthTimeout
等待获取分区信息的时间,以秒为单位。如果此计时器到期,运行状况将报告为已关闭。
默认值:10
- spring.cloud.stream.kafka.binder.requiredAcks
代理程序上所需的确认数。有关生产者
acks
属性的信息,请参见Kafka文档。默认值:
1
。- spring.cloud.stream.kafka.binder.minPartitionCount
仅在设置了
autoCreateTopics
或autoAddPartitions
时有效。活页夹在生成或使用数据的主题上配置的全局最小分区数。可以通过生产者的partitionCount
设置或生产者的instanceCount * concurrency
设置的值(如果任一个较大)来代替它。默认值:
1
。- spring.cloud.stream.kafka.binder.producer属性
任意Kafka客户端生产者属性的键/值映射。这里的Properties取代了启动时和上面的
configuration
属性中设置的所有属性。默认值:空地图。
- spring.cloud.stream.kafka.binder.replicationFactor
如果
autoCreateTopics
有效,则自动创建的主题的复制因子。可以在每个绑定上覆盖。默认值:
1
。- spring.cloud.stream.kafka.binder.autoCreateTopics
如果设置为
true
,则活页夹将自动创建新主题。如果设置为false
,则活页夹依赖于已配置的主题。在后一种情况下,如果主题不存在,则活页夹无法启动。默认值:
true
。此设置与代理的
auto.topic.create.enable
设置无关,并且不影响它。如果服务器设置为自动创建主题,则可以使用默认代理设置将它们作为元数据检索请求的一部分进行创建。- spring.cloud.stream.kafka.binder.autoAddPartitions
如果设置为
true
,则活页夹将根据需要创建新分区。如果设置为false
,则活页夹依赖于已配置的主题的分区大小。如果目标主题的分区数小于预期值,则活页夹无法启动。默认值:
false
。- spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix
在活页夹中启用事务。请参阅Kafka文档中的
transaction.id
和spring-kafka
文档中的Transactions。启用事务后,将忽略各个producer
属性,并且所有生产者都将使用spring.cloud.stream.kafka.binder.transaction.producer.*
属性。默认值
null
(无交易)- spring.cloud.stream.kafka.binder.transaction.producer。*
交易绑定中生产者的全球生产者属性。请参见
spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix
和“ Kafka生产者Properties”以及所有活页夹支持的常规生产者属性。默认值:请参见各个生产者属性。
- spring.cloud.stream.kafka.binder.headerMapperBeanName
KafkaHeaderMapper
的bean名称,用于将spring-messaging
标头映射到Kafka标头和从Kafka标头映射。例如,如果您希望自定义在标头中使用JSON反序列化的DefaultKafkaHeaderMapper
中的受信任软件包,请使用此方法。默认值:无。
更多建议: