java - Kafka Consumer不消费java中的所有记录

Question

我编写了一个 Kafka 消费者来从主题中获取所有记录，然后只转到下一步，但它并没有获取所有记录。

while (fetchedRecord) {

            ConsumerRecords<String, String> records = consumer.poll(10);
            System.out.println("Waiting for Records from Party-Resolved-Update");
            Thread.sleep(40000);
            for (ConsumerRecord<String, String> record : records) {

                System.out.println("Record fetched");
                end++;
                System.out.println(record.value());
                if (!StringUtils.isEmpty(record.value())) {
                    fetchedRecord = false;
                    response = record.value();

                    FSecurity sc = new FSecurity();
                    sc.init();
                    decryptResponse.add(sc.decryptData(response));
                    System.out.println("decryptResponse=" + decryptResponse);
                }


            }

        }

Answer 1

请正确描述您的问题。

假设您无法使用下一组记录。

解决方案将 enable.auto.commit 提供为 true，或者在代码中显式添加 consumer.commitSync() 语句。这将允许您轮询下一个偏移记录。