From 2064e25aff2c5365ba7c7f1da90f6ceacf916122 Mon Sep 17 00:00:00 2001
From: Samuel Cantero <scanterog@gmail.com>
Date: Tue, 2 Nov 2021 11:45:08 -0300
Subject: [PATCH] Add Default trait to Statistics

rdkafka publishes stats every configurable ms. Some of these properties
are ever increasing and requires us to calculate the difference between
the current value and the previous value (for example the 'tx' and
'txmsgs' fields). Setting a Default trait allow us to use the default
values for fields of the struct which are required on startup.
---
 Cargo.lock        |  2 +-
 src/statistics.rs | 16 ++++++++--------
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 679d3cbd5..906502328 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1123,7 +1123,7 @@ dependencies = [
 
 [[package]]
 name = "rdkafka"
-version = "0.27.0-alpha.0"
+version = "0.27.0"
 dependencies = [
  "async-std",
  "backoff",
diff --git a/src/statistics.rs b/src/statistics.rs
index 0d8c436e4..fabbe44c1 100644
--- a/src/statistics.rs
+++ b/src/statistics.rs
@@ -15,7 +15,7 @@ use std::collections::HashMap;
 use serde::Deserialize;
 
 /// Overall statistics.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct Statistics {
     /// The name of the librdkafka handle.
     pub name: String,
@@ -73,7 +73,7 @@ pub struct Statistics {
 }
 
 /// Per-broker statistics.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct Broker {
     /// The broker hostname, port, and ID, in the form `HOSTNAME:PORT/ID`.
     pub name: String,
@@ -168,7 +168,7 @@ pub struct Broker {
 ///
 /// These values are not exact; they are sampled estimates maintained by an
 /// HDR histogram in librdkafka.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct Window {
     /// The smallest value.
     pub min: i64,
@@ -202,7 +202,7 @@ pub struct Window {
 }
 
 /// A topic and partition specifier.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct TopicPartition {
     /// The name of the topic.
     pub topic: String,
@@ -211,7 +211,7 @@ pub struct TopicPartition {
 }
 
 /// Per-topic statistics.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct Topic {
     /// The name of the topic.
     pub topic: String,
@@ -226,7 +226,7 @@ pub struct Topic {
 }
 
 /// Per-partition statistics.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct Partition {
     /// The partition ID.
     pub partition: i32,
@@ -299,7 +299,7 @@ pub struct Partition {
 }
 
 /// Consumer group manager statistics.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct ConsumerGroup {
     /// The local consumer group handler's state.
     pub state: String,
@@ -321,7 +321,7 @@ pub struct ConsumerGroup {
 }
 
 /// Exactly-once semantics statistics.
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug, Default)]
 pub struct ExactlyOnceSemantics {
     /// The current idempotent producer state.
     pub idemp_state: String,