更改要在 Spring Kafka 中获取的记录数
Changing the number of records to fetch in Spring Kafka
我有一个 spring 引导服务，它有一个 kafka 消费者。我正在使用 spring-kafka 创建消费者。
根据文档，它说 max.poll.records 属性 将有助于限制要获取的记录数。
但我的问题是，我想根据其他几个条件更改 max.poll.records 的值。
我们如何使用 spring-kafka 实现此目的？任何帮助将不胜感激。
如果你的意思是在运行时改变它，那是做不到的； 属性 在创建消费者时发送到 Kafka。
要更改它，您必须停止容器，更改 属性，然后重新启动容器。您将需要一个自定义消费者工厂，它是 DefaultKafkaConsumerFactory 的子类并覆盖
protected KafkaConsumer<K, V> createKafkaConsumer(Map<String, Object> configs) {
在运行时更改 属性。
我有一个 spring 引导服务，它有一个 kafka 消费者。我正在使用 spring-kafka 创建消费者。
根据文档，它说 max.poll.records 属性 将有助于限制要获取的记录数。
但我的问题是，我想根据其他几个条件更改 max.poll.records 的值。
我们如何使用 spring-kafka 实现此目的？任何帮助将不胜感激。
如果你的意思是在运行时改变它，那是做不到的； 属性 在创建消费者时发送到 Kafka。
要更改它，您必须停止容器，更改 属性，然后重新启动容器。您将需要一个自定义消费者工厂，它是 DefaultKafkaConsumerFactory 的子类并覆盖
protected KafkaConsumer<K, V> createKafkaConsumer(Map<String, Object> configs) {
在运行时更改 属性。