Upgrade rdkafka to 0.11.4 (rustrdkafka to 0.16.0) (#436)

* Upgrade rdkafka to 0.11.4 (rustrdkafka to 0.16.0)
postmates · May 22, 2018 · ed4339e · ed4339e
1 parent 12520e9
commit ed4339e
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -38,7 +38,7 @@ openssl-probe = "0.1"
 protobuf = "1.4"
 quantiles = { version = "0.7", features = ["serde_support"] }
 rand = "0.4"
-rdkafka = "0.14.0"
+rdkafka = "0.16.0"
 regex = "0.2"
 rusoto_core = "0.30"
 rusoto_firehose = "0.30"

diff --git a/src/sink/kafka.rs b/src/sink/kafka.rs
@@ -1,7 +1,7 @@
 //! Kafka sink for Raw events.
 use futures::future::Future;
 use metric;
-use rdkafka::client::Context;
+use rdkafka::client::ClientContext;
 use rdkafka::config::{ClientConfig, RDKafkaLogLevel};
 use rdkafka::error::{KafkaError, RDKafkaError};
 use rdkafka::message::{Message, OwnedMessage};
@@ -33,7 +33,7 @@ impl STFUContext {
     }
 }
 
-impl Context for STFUContext {
+impl ClientContext for STFUContext {
     /// Receives log lines from librdkafka.
     fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str) {
         if !self.should_emit_message(log_message) {
@@ -673,7 +673,7 @@ mod tests {
         let producer = RetryOnceMockKafkaSender {
             call_count: Arc::new(RwLock::new(0)),
             send_entries: Arc::new(RwLock::new(Vec::new())),
-            error_type: KafkaError::FutureCanceled,
+            error_type: KafkaError::NoMessageReceived,
             fail_retry: true,
         };
         let mut k = Kafka {