SCDF 上下文中的 Kafka 消费者属性设置在哪里？
Where are Kafka consumer properties set in an SCDF context?
我正在尝试通过修补 max.poll.interval.ms、session.timeout.ms 和 heartbeat.interval.ms 来围绕 CommitFailedException 工作。我曾尝试在 application.properties 文件中更改这些值，但是当应用程序部署在 SCDF 上下文中时，我在此处设置的值会在其他地方被覆盖。当 运行 应用程序在本地作为独立 Spring 启动应用程序时，属性 值设置为与 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 部署；它也会以同样的方式运行。不应覆盖任何内容。
我正在尝试通过修补 max.poll.interval.ms、session.timeout.ms 和 heartbeat.interval.ms 来围绕 CommitFailedException 工作。我曾尝试在 application.properties 文件中更改这些值，但是当应用程序部署在 SCDF 上下文中时，我在此处设置的值会在其他地方被覆盖。当 运行 应用程序在本地作为独立 Spring 启动应用程序时，属性 值设置为与 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 部署；它也会以同样的方式运行。不应覆盖任何内容。