巴中哪里可以做公司网站,wordpress标签模板下载,织梦网站还原,如何做强企业网站bootstrap.servers #deserializer应该与producer保持对应 #key.deserializer #value.deserializer ##fetch请求返回时#xff0c;至少获取的字节数#xff0c;默认值为1 ##当数据量不足时#xff0c;客户端请求将会阻塞 ##此值越大#xff0c;客户端请求阻塞的时间越长 #deserializer应该与producer保持对应 #key.deserializer #value.deserializer ##fetch请求返回时至少获取的字节数默认值为1 ##当数据量不足时客户端请求将会阻塞 ##此值越大客户端请求阻塞的时间越长这取决于producer生产效率和网络传输能力 fetch.min.bytes1 ##如果broker端反馈的数据量不足时fetch.min.bytesfetch请求等待的最长时间 ##如果数据量满足需要则立即返回。 fetch.max.wait.ms500 ##标识consumer所属的group ##此属性非常重要类似于JMS订阅者的clientId ##同一个group中的consumer互为排他、且可以负载均衡。 ##即订阅topic的同一个group中任何一个partition只能被一个consumer消费 group.id ##consumer协调器与kafka集群之间心跳检测的时间间隔 ##kafka集群通过心跳判断consumer会话的活性以判断consumer是否在线如果离线则会把 ##此consumer注册的partition分配assign给相同group的其他consumer。 ##此值必须小于“session.timeout.ms”,即会话过期时间应该比心跳检测间隔要大通常为session.timeout.ms的三分之一否则心跳检测就失去意义。 heartbeat.interval.ms3000 ##单次fetch请求中server为每个partition返回的消息最大尺寸默认为1M ##因此每次fetch请求的最大数据量推算为partitions * max.partition.fetch.bytes max.partition.fetch.bytes1048576 ##consumer会话超时时长如果在此时间内server尚未接收到consumer任何请求包括心跳检测那么 ##server将会判定此consumer离线。 ##此值越大server等待consumer失效、rebalance时间就越长。 session.timeout.ms30000 ##当consumer指定的offset在kafka中不存在时比如首次消费、或者相应的offset log数据已经删除 ##earliest重置为kafka持有的最早的offset值即从kafka现存的最早的消息开始消费 ##latest重置为kafka持有的最新的offset值即从最新的消息开始消费 ##none如果broker不存在指定的offset的数据则直接抛出异常 auto.offset.resetlatest ##是否开启自动提交offset ##如果开启consumer已经消费的offset信息将会间歇性的提交到kafka中持久保存 enable.auto.committrue ##当开启offset自动提交时提交请求的时间频率 auto.commit.interval.ms5000 ##broker使用何种策略分配partition给consumer或许class应该放在broker端的classpath中 #partition.assignment.strategy ##单次请求超时时间比如poll、offset提交、心跳等请求 ##在超时之间无响应的请求则会重试直到超时或者重试次数达到阀值 request.timeout.ms40000 ##请求失败后重试之前backoff的时间 retry.backoff.ms100 ##通常情况下当consumer创建时将会获取kafka broker的metadata信息 ##当consumer消费时遇到特殊异常比如leader迁移、broker拓扑结构变迁也将会同步刷新metadata信息。 ##此配置用于限制即使没有检测到broker端metadata信息的变更也将强制进行metadata同步的时间周期。 metadata.max.age.ms300000
