我正在尝试通过修改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消费者属性？
max.poll.interval.ms，session.timeout.ms和heartbeat.interval.ms似乎是Kafka的使用者配置。
如果您打算在Spring Cloud Stream使用者中使用和覆盖它们，则必须使用spring.cloud.stream.kafka.bindings.input.consumer.configuration.foo=bar表示法。
在此示例中，其中foo可以是max.poll.interval.ms，而bar将是它的值：300000。有关更多详细信息，请参见ref. guide。
一旦在此模式中定义了所有所需的使用者属性，就可以通过java -jar在本地测试应用程序。然后，您可以确保从SCDF进行部署。它也将以相同的方式运行。什么都不会被覆盖。