我编写了一个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);
                }

            }

        }