时间戳

首页 > 解决方案 > Kafka 消费者属性在 SCDF 上下文中设置在哪里？

apache-kafka - Kafka 消费者属性在 SCDF 上下文中设置在哪里？

问题描述

我正在尝试CommitFailedException通过修补max.poll.interval.ms,session.timeout.ms和来解决问题heartbeat.interval.ms。我尝试在application.properties文件中更改这些值，但是当应用程序部署在 SCDF 上下文中时，我在此处设置的值会在其他地方被覆盖。当应用程序作为独立的 Spring Boot 应用程序在本地运行时，属性值设置为与application.properties文件中指定的相同。

dataflow-kafka 容器基于镜像confluentinc/cp-kafka:5.2.1

在 SCDF 上下文中，我在哪里调整 Kafka 消费者属性？

标签： apache-kafkaspring-cloud-streamspring-cloud-dataflow

解决方案

max.poll.interval.ms和似乎是 Kafka 的消费者session.timeout.ms配置。heartbeat.interval.ms

如果您打算在 Spring Cloud Stream 使用者中使用和覆盖它们，则必须使用spring.cloud.stream.kafka.bindings.input.consumer.configuration.foo=bar符号。

在这个例子中，where foocould be max.poll.interval.msand barwill be its value: 300000. 有关更多详细信息，请参阅参考文献。指导。

一旦您在此模式中定义了所有所需的使用者属性，您就可以通过在本地测试应用程序java -jar。然后，您可以确保从 SCDF 部署；它也会以同样的方式运行。什么都不应该被覆盖。

推荐阅读