diff --git a/src/consumer/stream_consumer.rs b/src/consumer/stream_consumer.rs index 12c925c2a..46782c9fc 100644 --- a/src/consumer/stream_consumer.rs +++ b/src/consumer/stream_consumer.rs @@ -160,7 +160,7 @@ impl<'a> Drop for MessageStream<'a> { /// the processing thread is wedged and leave the consumer groups. /// /// [KIP-62]: https://cwiki.apache.org/confluence/display/KAFKA/KIP-62%3A+Allow+consumer+to+send+heartbeats+from+a+background+thread -#[must_use = "Consumer polling thread will stop immediately if unused"] +#[must_use = "StreamConsumer does nothing unless .stream() is regularly polled"] pub struct StreamConsumer where C: ConsumerContext,