diff --git a/idk/kafka/source.go b/idk/kafka/source.go
index bc77cab43..6efdce8ce 100644
--- a/idk/kafka/source.go
+++ b/idk/kafka/source.go
@@ -233,11 +233,17 @@ func (r *Record) Commit(ctx context.Context) error {
 		p = x.Partition
 	}
 
-	_, err := r.src.CommitMessages(r.src.highmarks)
+	committedOffsets, err := r.src.CommitMessages(r.src.highmarks)
 	if err != nil {
 		return errors.Wrap(err, "failed to commit messages")
 	}
 
+	if r.src.Verbose {
+		for _, o := range committedOffsets {
+			r.src.Log.Debugf("p: %v o: %v t: %v", o.Partition, o.Offset, o.Topic)
+		}
+	}
+
 	r.src.spool = remaining
 	r.src.spoolBase = idx
 	return nil
@@ -316,6 +322,10 @@ func (s *Source) Open() error {
 		return errors.Wrap(err, "subscribe topics")
 	}
 
+	if s.Verbose {
+		s.Log.Debugf("subscribed to %v", s.Topics)
+	}
+
 	s.client = cl
 	s.opened = true
 	s.wg.Add(1)