message: chore: emphasize flush in docs
diff: //! producer.send(RecordKey::NULL, format!("Hello, Fluvio {}!", i)).await?;
  //! async_std::task::sleep(Duration::from_secs(1)).await;
  //! }
  +//! // fluvio batches records by default, so call flush() when done producing to ensure all
  +//! // records are sent
  +//! producer.flush().await?;
  //! Ok(())
  //! }
  //!
  @@ -162,6 +165,24 @@ const MINIMUM_PLATFORM_VERSION: &str = "0.9.0";
  /// # }
  /// ```
  ///
  +/// # Example: Flushing
  +///
  +/// Fluvio batches records by default, so it's important to flush the producer before terminating.
  +///
  +/// ```no_run
  +/// # use fluvio::FluvioError;
  +/// # use fluvio_protocol::record::RecordKey;
  +/// # async fn produce_records() -> Result<(), FluvioError> {
  +/// let producer = fluvio::producer("echo").await?;
  +/// for i in 0..10u8 {
  +/// producer.send(RecordKey::NULL, format!("Hello, Fluvio {}!", i)).await?;
  +/// }
  +/// producer.flush().await?;
  +/// # Ok(())
  +/// # }
  +/// ```
  +///
  +///
  /// [`Fluvio`]: ./struct.Fluvio.html
  #[instrument(skip(topic))]
  pub async fn producer<S: Into<String>>(topic: S) -> Result<TopicProducer, FluvioError> {
  