kafka thời gian chờ bỏ phiếu của người tiêu dùng

Question

Tôi đang làm việc với Kafka và cố gắng tiêu thụ dữ liệu từ nó. Từ dòng dưới đây, tôi có thể thăm dò dữ liệu từ Kafka.

while (true) { 
    ConsumerRecords<byte[], <byte[]> records = consumer.poll(Long.MAX_VALUE); 
    for (ConsumerRecord<byte[], <byte[]> record : records) { 
     // retrieve data 
    } 
    } 

Câu hỏi của tôi là lợi ích Tôi nhận được bằng cách cung cấp Long.MAX_VALUE như thời gian chờ so với nếu tôi cung cấp 200 như thời gian chờ là gì. Thực hành tốt nhất cho hệ thống sẽ chạy sản xuất là gì.

Bất cứ ai có thể giải thích cho tôi sự khác biệt về thời gian chờ cao và thời gian chờ thấp và nên được sử dụng trong hệ thống sản xuất?

Answer 1

Đặt MAX_VALUE là loại tiêu thụ tin nhắn đồng bộ, chờ cho đến khi chúng tôi nhận được nội dung nào đó được trả về từ cuộc thăm dò, trong khi cài đặt ở giá trị thấp hơn sẽ cho bạn cơ hội quyết định làm điều gì khác ngoài chờ đợi. Mà nên được sử dụng phụ thuộc vào kịch bản thực tế của bạn.