kafka consumer属性
consumer属性
group.id
:指定consumer group的唯一标识。
consumer.id
:唯一标识consumer。默认值为null
,不指定时会自动生成。
zookeeper.connect
:指定ZooKeeper的连接字符串,格式为<hostname:port/chroot/path>
。/chroot/path
为全局ZooKeeper命名空间内的数据位置。
client.id
:标识发起请求的客户端。默认值为${group.id}
。
zookeeper.session.timeout.ms
:指定一个时间(毫秒)用于consumer等待ZooKeeper声明失效或重新均衡。默认值为6000
。
zookeeper.connection.timeout.ms
:指定客户端建立ZooKeeper连接的最大等待时间(毫秒)。默认值为6000
。
zookeeper.sync.time.ms
:指定ZooKeeper follower同步leader的时间(毫秒)。默认值为2000
。
auto.commit.enable
:该属性为true时,已经被consumer获取的消息offset会被阶段性提交ZooKeeper中。在consumer失效时新consumer将以提交的offset作为起始位置。默认值为true
。
auto.commit.interval.ms
:指定已被消费的offset提交到ZooKeeper的频率(毫秒)。默认值为60*1000
。
auto.offset.reset
:指定offset值,如果ZooKeeper中有初始offset或者offset超出范围。可选值有:largest
重新设置为最大的offset;smallest
重新设置为最小的offset;其他任意值抛出异常。默认值为largest
。
consumer.timeout.ms
:在指定的消息间隔后没有可被消费的消息时向consumer抛出一个异常。默认值为-1
。
原文地址:https://www.cnblogs.com/fanguangdexiaoyuer/p/5984879.html