Kafka两种配置文件方式

1.yml配置文件(简单配置)

spring:   kafka:     bootstrap-servers: ip:端口     consumer:       group-id: group-test       enable-auto-commit: true       auto-commit-interval: 1000ms       auto-offset-reset: latest       key-deserializer: org.apache.kafka.common.serialization.StringDeserializer       value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

2.类配置方式(使用了SASL/PLAINTEXT安全认证协议)

出现[Consumer clientId=consumer-1, groupId=group1] Bootstrap broker xxx (id: -1 r

版权声明:玥玥 发表于 2021-05-11 23:27:12。
转载请注明:Kafka两种配置文件方式 | 女黑客导航