Merge pull request #196 from influxdata/crepererum/fix_chrono_deprecations

fix: `chrono` deprecation warnings

Author: kodiakhq[bot]

benches/throughput.rs

@@ -42,7 +42,7 @@ pub fn criterion_benchmark(c: &mut Criterion) {
         key: Some(vec![b'k'; 10]),
         value: Some(vec![b'x'; 10_000]),
         headers: BTreeMap::default(),
-        timestamp: Utc.timestamp_millis(1337),
+        timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
     };
 
     {

src/client/consumer.rs

@@ -517,7 +517,7 @@ mod tests {
             key: Some(vec![0; 4]),
             value: Some(vec![0; 6]),
             headers: Default::default(),
-            timestamp: Utc.timestamp_millis(1337),
+            timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
         };
 
         let (sender, receiver) = mpsc::channel(10);
@@ -584,7 +584,7 @@ mod tests {
             key: Some(vec![0; 4]),
             value: Some(vec![0; 6]),
             headers: Default::default(),
-            timestamp: Utc.timestamp_millis(1337),
+            timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
         };
 
         let (sender, receiver) = mpsc::channel(10);
@@ -675,7 +675,7 @@ mod tests {
             key: Some(vec![0; 4]),
             value: Some(vec![0; 6]),
             headers: Default::default(),
-            timestamp: Utc.timestamp_millis(1337),
+            timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
         };
 
         // Simulate an error on first fetch to encourage an offset update
@@ -722,7 +722,7 @@ mod tests {
             key: Some(vec![0; 4]),
             value: Some(vec![0; 6]),
             headers: Default::default(),
-            timestamp: Utc.timestamp_millis(1337),
+            timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
         };
 
         // Simulate an error on first fetch to encourage an offset update

src/client/producer.rs

@@ -737,7 +737,7 @@ mod tests {
             key: Some(vec![0; 4]),
             value: Some(vec![0; 6]),
             headers: Default::default(),
-            timestamp: Utc.timestamp_millis(320),
+            timestamp: Utc.timestamp_millis_opt(320).unwrap(),
         }
     }
 

src/client/producer/aggregator.rs

@@ -153,7 +153,7 @@ mod tests {
             key: Some(vec![0; 45]),
             value: Some(vec![0; 2]),
             headers: Default::default(),
-            timestamp: Utc.timestamp_millis(1337),
+            timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
         };
 
         let r2 = Record {

src/record.rs

@@ -45,7 +45,7 @@ mod tests {
             headers: vec![("a".to_string(), vec![0; 5]), ("b".to_string(), vec![0; 7])]
                 .into_iter()
                 .collect(),
-            timestamp: Utc.timestamp_millis(1337),
+            timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
         };
 
         assert_eq!(record.approximate_size(), 23 + 45 + 1 + 5 + 1 + 7);

tests/client.rs

@@ -685,6 +685,6 @@ pub fn large_record() -> Record {
         key: Some(b"".to_vec()),
         value: Some(vec![b'x'; 1024]),
         headers: BTreeMap::from([("foo".to_owned(), b"bar".to_vec())]),
-        timestamp: Utc.timestamp_millis(1337),
+        timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
     }
 }

tests/java_helper.rs

@@ -278,7 +278,7 @@ pub async fn consume(
                 key: Some(key.as_bytes().to_vec()),
                 value: Some(value.as_bytes().to_vec()),
                 headers,
-                timestamp: Utc.timestamp_millis(timestamp),
+                timestamp: Utc.timestamp_millis_opt(timestamp).unwrap(),
             };
             let record_and_offset = RecordAndOffset { record, offset };
             results.push(record_and_offset);

tests/produce_consume.rs

@@ -269,7 +269,7 @@ async fn assert_produce_consume<F1, G1, F2, G2>(
     );
 
     // timestamps for records. We'll reorder the messages though to ts2, ts1, ts3
-    let ts1 = Utc.timestamp_millis(1337);
+    let ts1 = Utc.timestamp_millis_opt(1337).unwrap();
     let ts2 = ts1 + Duration::milliseconds(1);
     let ts3 = ts2 + Duration::milliseconds(1);
 

tests/rdkafka_helper.rs

@@ -114,7 +114,8 @@ pub async fn consume(
                             })
                             .unwrap_or_default(),
                         timestamp: Utc
-                            .timestamp_millis(msg.timestamp().to_millis().unwrap_or_default()),
+                            .timestamp_millis_opt(msg.timestamp().to_millis().unwrap_or_default())
+                            .unwrap(),
                     },
                     offset: msg.offset(),
                 })

tests/test_helpers.rs

@@ -160,7 +160,7 @@ pub fn record(key: &[u8]) -> Record {
         key: Some(key.to_vec()),
         value: Some(b"hello kafka".to_vec()),
         headers: BTreeMap::from([("foo".to_owned(), b"bar".to_vec())]),
-        timestamp: Utc.timestamp_millis(1337),
+        timestamp: Utc.timestamp_millis_opt(1337).unwrap(),
     }
 }