【发布时间】:2022-12-26 00:52:48
【问题描述】:
spring Kafka 所需的配置是什么?
【问题讨论】:
标签: java spring-boot apache-kafka spring-kafka apache-kafka-connect
spring Kafka 所需的配置是什么?
【问题讨论】:
标签: java spring-boot apache-kafka spring-kafka apache-kafka-connect
您需要在 application.yml 中为生产者和消费者添加属性以使其正常工作。
spring:
kafka:
properties:
security.protocol: SSL
ssl:
endpoint:
identification:
algorithm: ''
consumer:
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
bootstrap-servers: kafka-url:9093
group-id: "group-id"
auto-offset-reset: latest
enable-auto-commit: true
ssl:
keystore-location: file:
truststore-location: file:
keystore-password:
truststore-password:
producer:
bootstrap-servers: kafka-url:9093
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
ssl:
keystore-location: file:
truststore-location: file:
keystore-password:
truststore-password:
【讨论】: