你用的是什么客户？可能有必要为耗电元件设置起始偏移量。看看seek（）函数和auto commit设置。也许我的代码有帮助，但也许我们使用不同的消费类(mine:http：//kafka python.readthedocs.org/en/latest/apidoc/kafka.consumer.html）：

def connect(self):
        '''Initialize Kafka Client and Consumer.'''
        try:
            print "Try to init KafkaClient:", self.Brokers
            self.__kafka_client = KafkaClient( self.Brokers )

            print "Try to init Kafka Consumer."
            self.__consumer = SimpleConsumer(
                    self.__kafka_client,
                    self.GroupID,
                    self.Topic,
                    auto_commit = True,
                    partitions=self.Partitions,
                    auto_commit_every_n = 100,
                    auto_commit_every_t=5000,
                    fetch_size_bytes=4096,
                    buffer_size=4096,
                    max_buffer_size=32768,
                    iter_timeout=None,
                    auto_offset_reset='largest' )

            print "Set the starting offset."
            self.__consumer.seek(0, self.OffsetMode)

self.__consumer.seek(0, 0) =>start reading from the beginning of the queue.
self.__consumer.seek(0, 1) =>start reading from current offset.
self.__consumer.seek(0, 2) =>skip all the pending messages and start reading only new messages (**maybeyour case**).