it should be easy to fix by just removing

getUnfilteredMessageCount

from

MessageBatch

and replacing it with

boolean allMessagesInvalid

or something to that effect, then track if all the messages are tombstones in the partition level consumer