我使用此配置創(chuàng)建一個新消費者：c, err := kafka.NewConsumer(&kafka.ConfigMap{                 "bootstrap.servers": addresses,                 "group.id":          "my_group",                 "auto.offset.reset": "earliest",         })topic := "testTopic"if err = c.SubscribeTopics([]string{topic}, nil); err != nil {    panic(err)}然后我根據(jù)以下代碼生成事件并使用一個事件：events := []map[string]string{{                                             "name":       "Foo",},                                                 {                                                          "name":       "Bar",                                                       },                                                 }                                                                                                                                                              err = p.ProduceEvent(events[0])//there is a wrapper to produce events       err = p.ProduceEvent(events[1])                                                                                                                       res, err := c.ReadMessage(100 * time.Second)                                              time.Sleep(20 * time.Second)                                                                                                                                                                     c.Close()                                  當(dāng)我用 描述該組時  watch /home/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group my_group  --describe。每一步的結(jié)果是：產(chǎn)生事件后： 當(dāng)我消費一個事件時： 關(guān)閉消費者后： 我不明白為什么最后滯后為零！我只消耗了一個事件。這對我來說很奇怪，那Close會改變偏移量。任何線索表示贊賞。