Update consume.py

rerpha · web-flow · commit af0184f25fa6 · 2025-06-18T14:12:11.000+01:00
diff --git a/src/saluki/consume.py b/src/saluki/consume.py
@@ -53,7 +53,7 @@ def consume(
                 - num_messages
             )
 
-    logger.info(f"starting at {start}")
+    logger.info(f"starting at offset {start}")
     c.assign([TopicPartition(topic, partition, start)])
 
     try:

Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,7 @@ def consume(`
`53`	`53`	`- num_messages`
`54`	`54`	`)`
`55`	`55`
`56`		`- logger.info(f"starting at {start}")`
	`56`	`+ logger.info(f"starting at offset {start}")`
`57`	`57`	`c.assign([TopicPartition(topic, partition, start)])`
`58`	`58`
`59`	`59`	`try:`