fix warnings

streamnative · Mar 5, 2021 · 5a5ca11 · 5a5ca11
1 parent 0afe6e6
commit 5a5ca11
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -141,7 +141,6 @@ extern crate futures;
 extern crate log;
 #[macro_use]
 extern crate nom;
-#[macro_use]
 extern crate prost_derive;
 
 #[cfg(test)]

diff --git a/src/message.rs b/src/message.rs
@@ -505,7 +505,7 @@ impl BatchedMessage {
 pub mod proto {
     include!(concat!(env!("OUT_DIR"), "/pulsar.proto.rs"));
 
-    //trait implermentations used in Consumer::unacked_messages
+    //trait implementations used in Consumer::unacked_messages
     impl std::cmp::Eq for MessageIdData {}
 
     impl std::hash::Hash for MessageIdData {

diff --git a/src/service_discovery.rs b/src/service_discovery.rs
@@ -6,7 +6,7 @@ use crate::message::proto::{
     CommandLookupTopicResponse,
 };
 use futures::{future::try_join_all, FutureExt};
-use std::{sync::Arc, time::Duration};
+use std::sync::Arc;
 use url::Url;
 
 /// Look up broker addresses for topics and partitioned topics