logs(consumer): fix info log when consumer partitions revoked (#494)

john-z-yang · web-flow · commit 7c965829b071 · 2025-10-06T14:07:06.000-07:00
diff --git a/src/kafka/consumer.rs b/src/kafka/consumer.rs
@@ -162,7 +162,7 @@ impl ConsumerContext for KafkaContext {
                     Event::Revoke(tpl.to_topic_map().keys().cloned().collect()),
                     rendezvous_sender,
                 ));
-                info!("Partition assignment event sent, waiting for rendezvous...");
+                info!("Partition revocation event sent, waiting for rendezvous...");
                 let _ = rendezvous_receiver.recv();
                 info!("Rendezvous complete");
             }

Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ impl ConsumerContext for KafkaContext {`
`162`	`162`	`Event::Revoke(tpl.to_topic_map().keys().cloned().collect()),`
`163`	`163`	`rendezvous_sender,`
`164`	`164`	`));`
`165`		`- info!("Partition assignment event sent, waiting for rendezvous...");`
	`165`	`+ info!("Partition revocation event sent, waiting for rendezvous...");`
`166`	`166`	`let _ = rendezvous_receiver.recv();`
`167`	`167`	`info!("Rendezvous complete");`
`168`	`168`	`}`