stoewer/go-nakadi

Fix Notify callback calls in go-nakadi.Processor

Closed this issue · 0 comments

krnkl commented

when cursor is commited error is not checked and Notify callback is not called:

        ....
		stream.CommitCursor(cursor)
	}

Moreover, error on line
is shadowed an thus not reported to callback notify function:

        err = operation(streamNo, cursor.NakadiStreamID, events)
	if err != nil {
	    err = stream.
            if err != nil {
                   options.NotifyErr(err, 0)
	}