如何为Kafka REST Proxy客户端配置max.poll.interval.ms及解决配置失效问题

当然可以配置通过Kafka REST Proxy连接的消费者参数，但你之前的配置方式有误，导致参数未生效。

• 正确的配置方式：在kafka-rest.properties中设置消费者参数时，必须给参数加上consumer.前缀。你需要把配置改成：

  consumer.max.poll.interval.ms=430000
  

  Kafka REST Proxy会将所有以consumer.开头的参数传递给底层的Kafka消费者客户端，而顶级的max.poll.interval.ms会被当作服务自身的配置，不会被消费者实例读取。

• 验证生效步骤：修改配置后，务必重启Kafka REST Proxy服务以加载新配置。重启后可通过两种方式验证：

  1. 查看服务日志，搜索max.poll.interval.ms，确认消费者初始化时使用了430000这个值；
  2. 通过REST API创建消费者时，在请求体的配置字段中指定该参数（此方式会覆盖全局配置），示例请求体：

     {
       "name": "my_consumer",
       "format": "json",
       "auto.offset.reset": "latest",
       "max.poll.interval.ms": 430000
     }
     

内容的提问来源于stack exchange，提问作者Darg