A commit represents the instruction of publishing an update of the last offset read by a program for a topic and partition.
| 3 | // A commit represents the instruction of publishing an update of the last |
| 4 | // offset read by a program for a topic and partition. |
| 5 | type commit struct { |
| 6 | topic string |
| 7 | partition int |
| 8 | offset int64 |
| 9 | } |
| 10 | |
| 11 | // makeCommit builds a commit value from a message, the resulting commit takes |
| 12 | // its topic, partition, and offset from the message. |