Closed AkiraTamai closed 3 years ago
Nice to meet you, here is the issue report.
I think that not enabled to skip SetCheckpoint in the case of ScanFunc return value(ErrSkipCheckpoint).
The following code was confirmed.
master/consumer.go#L202-L210
Sorry. I was mistaken. Please close. functioning.
Thanks for the note 👍
Nice to meet you, here is the issue report.
I think that not enabled to skip SetCheckpoint in the case of ScanFunc return value(ErrSkipCheckpoint).
The following code was confirmed.
master/consumer.go#L202-L210