1.session.timeout.ms
消费者在被认为死亡之前可以与服务器断开连接的时间,默认是3s。网络差的时候可以调长一些
2.auto.offset.reset
默认值为latest,在偏移量无效的情况下,消费者将从最新的记录开始读取数据
另一个值是earliest,在偏移量无效的情况下,消费者将从起始位置读取分区的记录。
3.enable.auto.commit
该属性指定了消费者是否自动提交偏移量,默认值是true。为了尽量避免出现重复数据和数据丢失,可以把它设为false,由自己控制何时提交偏移量。
网友评论