Kafka消费者-重要参数

1.fetch.min.bytes

consumer一次拉取中拉取的最小数据量,默认值为1B

2.fetch.max.bytes

consumer一次拉取中拉取的最大数据量,默认值为52428800B,即50MB

3.fetch.max.wait.ms

指定Kafka的等待时间,默认值为500ms,如果消息不够多满足不了最小的拉取量,则等待该时间

4.max.partition.fetch.bytes

配置从每个分区里返回给consumer的最大数据量

5.max.poll.records

配置consumer在一次拉取请求中拉取的最大消息数,默认为500条

6.connections.max.idle.ms

空连接超时限制

7.exclude.internal.topics

指定Kafka中的内部主题是否可以向消费者公开,默认为true,为true则只能使用subscribe(Collection)的方式而不能使用subscribe(Pattern)的方式来订阅内部主题

8.receive.buffer.bytes

设置socket接收消息缓冲区大小,默认值为65536B,即64KB

9.send.buffer.bytes

设置socket发送消息缓冲区大小,默认值为131072B,即128KB

10.request.timeout.ms

consumer等待请求响应的最长时间,默认为30000ms

11.metadata.max.age.ms

元数据过期时间,默认300000ms,即5分钟,如果元数据在该时间内没更新则强制更新

12.reconnect.backoff.ms

尝试重新连接主机之前等待时间,默认50ms,避免频繁连接

13.retry.backoff.ms

尝试重新发送失败的请求到指定主题分区之前的等待时间,默认100ms

14.isolation.level

事务隔离级别,有“read_uncommitted”和“read_committed”两种,默认情况为read_uncommitted,可以消费到HW处的位置

原文地址:https://www.cnblogs.com/jordan95225/p/13393954.html