文章/答案/技术大牛

发布

社区首页 >问答首页 >当自动提交为真时，弹簧云流卡夫卡绑定健康指示器失败

问当自动提交为真时，弹簧云流卡夫卡绑定健康指示器失败
EN

Stack Overflow用户

提问于 2021-04-30 01:59:52

回答 1查看 644关注 0票数 0

我们正在使用Kafka绑定构建带有Spring云流的定制DB Sink。我们使用以下版本的Spring和Spring

<spring-cloud.version>Hoxton.SR11</spring-cloud.version>
<spring.boot.version>2.3.4.RELEASE</spring.boot.version>

春云流卡夫卡绑定依赖-

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>

Sink工作得很好，但是执行器的健康端点总是在下降。

在调试了用于健康检查的KafkaBinderHealthIndicator流之后，导致此失败的根本原因是使用空客户端ID和组ID创建的Kafka使用者。

org.apache.kafka.common.errors.InvalidConfigurationException: enable.auto.commit cannot be set to true when default group id (null) is used.

我们必须使用/驱动器/健康作为应用健康指标，这已经成为显示停止。

请让我们知道哪个版本的Spring和Spring可以为绑定器健康工作。

spring-cloud-stream

发布于 2021-04-30 12:45:58

您不应该将enable.auto.commit=true与SCSt结合使用--当侦听器正常返回时，框架将自动处理提交偏移量。

这比Apache的自动提交机制更具确定性。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/67327261

复制

相似问题

问当自动提交为真时，弹簧云流卡夫卡绑定健康指示器失败EN