我正试图阅读Kafka中最早/最古老的信息，这是以前没有读过的。

import json

from kafka import KafkaConsumer
from kafka import KafkaProducer

ORDER_KAFKA_TOPIC = "order_details"
ORDER_CONFIRMED_KAFKA_TOPIC = "order_confirmed"

consumer = KafkaConsumer(
    ORDER_KAFKA_TOPIC,
    bootstrap_servers="localhost:29092",
    auto_offset_reset = "earliest",
    enable_auto_commit=False,

)

print("Gonna start listening")
while True:
    for message in consumer:

        print("Ongoing transaction..")
        consumed_message = json.loads(message.value.decode())
        print(consumed_message)

我已经设置了参数：

auto_offset_reset = "earliest",
    enable_auto_commit=False,

根据文件：
创建使用者时，enable_auto_commit选项设置为False。这意味着使用者不会自动提交其偏移量，因此它将仅接收其他使用者尚未提交的消息。这允许使用者仅读取主题中的未读消息。
但是，我仍然收到已阅读的消息。