首页 笔记 图片 查字 
所属分类:Kafka
浏览:57
内容:

1. 消费者主要配置参数:
bootstrap.servers
key.deserializer/value.deserializer
group.id
enable.auto.commit
auto.commit.interval.ms
auto.offset.reset
offsets.topic.num.partitions
heartbeat.interval.ms
session.timeout.ms
max.pool.interval.ms
fetch.max.bytes
max.poll.records

2. 消费者再平衡
heartbeat.interval.ms
session.timeout.ms
max.poll.interval.ms
partiton.assignment.strategy

3. 指定offset消费
4. 指定时间消费
5. 消费者事务
6. 消费者如何提高吞吐量
增加主题分区数量
fetch.max.bytes
max.poll.records