Encounter two questions about calling ResetOffset
Versions
Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.
| Sarama | Kafka | Go | GoLand |
|---|---|---|---|
| 1.37 | 2.5.0 | 1.17.11 | 2021.3.3 |
Configuration
What configuration values are you using for Sarama and Kafka?
Consumer.Offsets.AutoCommit.Enable = false
Kafka Topics [k, kk] Kafka Clusters: 3 servers Topic k, with partitions[0,1,2] Topic kk, with partition [0]
There are two testings for interface ResetOffset :
- Reset offset for topic kk, partition 0, and start offset at 11
session.ResetOffset("kk", 0, 11, "")
- Reset offset for topic kk, partition 0, and start offset at 11, and reset offset for topic k, partition 0, and start offset at 1318895
session.ResetOffset("kk", 0, 11, "")
session.ResetOffset("k", 0, 1318895, "")
For Testing 1 Console Output

For Testing 2 Console Output

Problem Description
For Testing 1, we may find the consume time almost 5 seconds with receive 9 messages (Just Receive, did not handle anything), why it so slow for reseting offset to consume ?
For Testing 2, we also find the same issue with Testing 1, what's more, we may find two message missing when reset to consume,
for topic kk, the message with offset 11 not to receive to consume;
for topic k, the message with offset 1318895 not to receive to consume, which both the beginning offset message that specificed.