props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 1);, so đó poll đủ số lượng em cần thì thôi em ạ. Ví dụ:
List buffer = new ArrayList();
while (true) {
final ConsumerRecords consumerRecords =
consumer.poll(1000);
if (consumerRecords.count() > 0) {
buffer.add(rs.iterator().next());
}
consumer.commitAsync();
if (buffer.size() >= so luong phan tu can lay) {
break;
}
}
consume buffers
buffers.clear();
Login to our social questions & Answers Engine to ask questions answer people’s questions & connect with other people.
Sign Up to our social questions and Answers Engine to ask questions, answer people’s questions, and connect with other people.
