我使用kafka队列来保存消费者应用程序要检索的一些对象，并对其执行一些操作。
问题：如果消费者的处理时间超过2小时，Kafka似乎会一次又一次地回馈同一个物体
代码：

private static Queue queue = new LinkedList();
  while (true) {
            ConsumerRecords<String, String> records = consumer.poll(Long.MAX_VALUE);
            for (ConsumerRecord<String, String> record : records) {
                System.out.println("\n\n\n Kafka has :[" + record.offset());
                queue.add(record.value());
            }
            System.out.println("\n\n\n Kafka has :[" + records.count());
            if (queue != null) {
                maintainQueue();
            }
        }