1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/jobs/brokers/ephemeral/item.go b/plugins/jobs/brokers/ephemeral/item.go
index 40c6b3e4..76e83d00 100644
--- a/plugins/jobs/brokers/ephemeral/item.go
+++ b/plugins/jobs/brokers/ephemeral/item.go
@@ -118,10 +118,12 @@ func (j *Item) Context() ([]byte, error) {
 	return ctx, nil
 }
 
-func (j *Item) Ack() {
+func (j *Item) Ack() error {
 	// noop for the in-memory
+	return nil
 }
 
-func (j *Item) Nack() {
+func (j *Item) Nack() error {
 	// noop for the in-memory
+	return nil
 }