我用的是spotify docker版的Kafka。我现在只有一个生产者，一个经纪人和一个消费者。
问题是，使用这种配置，我无法从Kafka获得最新消息。如果我默认 auto_offset_reset='earliest' 然后我收到了所有的信息。
这是我给消费者的代码，即使Kafka上有新的信息，它也不会打印任何信息。

def consumer():
consumer = KafkaConsumer('stories',
                         enable_auto_commit=False,
                         value_deserializer=lambda m: json.loads(m.decode('ascii')),
                         bootstrap_servers=['127.0.0.1:9092'],
                         auto_offset_reset='latest',
                         consumer_timeout_ms=1000
                         )

for message in consumer:
    # message value and key are raw bytes -- decode if necessary!
    # e.g., for unicode: `message.value.decode('utf-8')`
    print("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
                                         message.offset, message.key,
                                         message.value))

有人能帮我一下，告诉我哪里出了问题吗？
我只是想从Kafka中得到消费者没有读到的信息。
以下是Kafka消费者：https://hastebin.com/umuhugacez.py
Kafka制作人：https://hastebin.com/laderolawi.py