Kafka消费者

2020-06-12 本文已影响0人右腕

consumer 采用 pull（拉）模式从 broker 中读取数据。

为了防止没有数据时consumer还在请求数据，consumer在消费数据时会传入一个时长参数 timeoutconsumer 会等待timeout之后再请求数据。