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处的位置