Looks like a type error in your consumer? Try changing the type of

batch

to just

MessageBatch

instead of

MessageBatch<Error>