// Handler возвращает BatchResult
func handleBatch(events []*MyEvent) databus.BatchResult {
processed := 0
skipped := 0
for _, event := range events {
if event == nil {
skipped++
continue
}
if err := processEvent(event); err != nil {
return databus.Nack()
}
processed++
}
return databus.Acks(processed,
databus.WithSkips(skipped))
}