Kafka 配置ConsumerConfig
1.group.id 消费者所属消费组的唯一标识
2.max.poll.records 一次拉取请求的最大消息数,默认500条
3.max.poll.interval.ms 指定拉取消息线程最长空闲时间,默认300000ms
4.session.timeout.ms 检测消费者是否失效的超时时间,默认10000ms
5.heartbeat.interval.ms 消费者心跳时间,默认3000ms
6.bootstrap.servers 连接集群broker地址
7.enable.auto.commit 是否开启自动提交消费位移的功能,默认true
8.auto.commit.interval.ms 自动提交消费位移的时间间隔,默认5000ms
9.partition.assignment.strategy 消费者的分区配置策略, 默认 RangeAssignor
10.auto.offset.reset 如果分区没有初始偏移量,或者当前偏移量服务器上不存在时,将使用的偏移量设置,earliest从头开始消费,latest从最近的开始消费,none抛出异常
11.fetch.min.bytes 消费者客户端一次请求从Kafka拉取消息的最小数据量,如果Kafka返回的数据量小于该值,会一直等待,直到满足这个配置大小,默认1b
12.fetch.max.bytes 消费者客户端一次请求从Kafka拉取消息的最大数据量,默认50MB
13.fetch.max.wait.ms 从Kafka拉取消息时,在不满足fetch.min.bytes条件时,等待的最大时间,默认500ms
14.metadata.max.age.ms 强制刷新元数据时间,毫秒,默认300000,5分钟
15.max.partition.fetch.bytes 设置从每个分区里返回给消费者的最大数据量,区别于fetch.max.bytes,默认1MB
16.send.buffer.bytes Socket发送缓冲区大小,默认128kb,-1将使用操作系统的设置
17.receive.buffer.bytes Socket发送缓冲区大小,默认64kb,-1将使用操作系统的设置
18.client.id 消费者客户端的id
19.reconnect.backoff.ms 连接失败后,尝试连接Kafka的时间间隔,默认50ms
20.reconnect.backoff.max.ms 尝试连接到Kafka,生产者客户端等待的最大时间,默认1000ms
21.retry.backoff.ms 消息发送失败重试时间间隔,默认100ms
22.metrics.sample.window.ms 样本计算时间窗口,默认30000ms
23.metrics.num.samples 用于维护metrics的样本数量,默认2
24.metrics.log.level metrics日志记录级别,默认info
25.metric.reporters 类的列表,用于衡量指标,默认空list
26.check.crcs 自动检查CRC32记录的消耗
27.key.deserializer key反序列化方式
28.value.deserializer value反序列化方式
29.connections.max.idle.ms 设置多久之后关闭空闲连接,默认540000ms
30.request.timeout.ms 客户端将等待请求的响应的最大时间,如果在这个时间内没有收到响应,客户端将重发请求,超过重试次数将抛异常,默认30000ms
31.default.api.timeout.ms 设置消费者api超时时间,默认60000ms
32.interceptor.classes 自定义拦截器
33.exclude.internal.topics 内部的主题:一consumer_offsets 和一transaction_state。该参数用来指定 Kafka 中的内部主题是否可以向消费者公开,默认值为 true。如果设置为 true,那么只能使用 subscribe(Collection)的方式而不能使用 subscribe(Pattern)的方式来订阅内部主题,设置为 false 则没有。
34.isolation.level 用来配置消费者的事务隔离级别。如果设置为“read committed”,那么消费者就会忽略事务未提交的消息,即只能消 费到 LSO (LastStableOffset)的位置,默认情况下为 “read_uncommitted”,即可以消 费到 HW (High Watermark)处的位置
这篇好文章是转载于:学新通技术网
- 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
- 本站站名: 学新通技术网
- 本文地址: /boutique/detail/tanhgagjjj
-
photoshop保存的图片太大微信发不了怎么办
PHP中文网 06-15 -
Android 11 保存文件到外部存储,并分享文件
Luke 10-12 -
word里面弄一个表格后上面的标题会跑到下面怎么办
PHP中文网 06-20 -
《学习通》视频自动暂停处理方法
HelloWorld317 07-05 -
photoshop扩展功能面板显示灰色怎么办
PHP中文网 06-14 -
微信公众号没有声音提示怎么办
PHP中文网 03-31 -
excel下划线不显示怎么办
PHP中文网 06-23 -
怎样阻止微信小程序自动打开
PHP中文网 06-13 -
excel打印预览压线压字怎么办
PHP中文网 06-22 -
photoshop蒙版画笔没反应怎么办
PHP中文网 06-24