From b1abda2491aa952bc518fbe4936881d688bcb70c Mon Sep 17 00:00:00 2001
From: "Jorge C. Leitao" <jorgecarleitao@gmail.com>
Date: Wed, 13 Jul 2022 03:43:30 +0000
Subject: [PATCH] Made kafka schema_id u32

---
 examples/avro_kafka.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/examples/avro_kafka.rs b/examples/avro_kafka.rs
index 0ee461a5b77..5fb392fd93a 100644
--- a/examples/avro_kafka.rs
+++ b/examples/avro_kafka.rs
@@ -4,7 +4,7 @@ use arrow2::{
     io::avro,
 };
 
-fn read_schema_id<R: std::io::Read>(reader: &mut R) -> Result<i32, Error> {
+fn read_schema_id<R: std::io::Read>(reader: &mut R) -> Result<u32, Error> {
     let mut header = [0; 5];
     reader.read_exact(&mut header)?;
 
@@ -13,7 +13,7 @@ fn read_schema_id<R: std::io::Read>(reader: &mut R) -> Result<i32, Error> {
             "Avro requires the first byte to be a zero".to_string(),
         ));
     }
-    Ok(i32::from_be_bytes(header[1..].try_into().unwrap()))
+    Ok(u32::from_be_bytes(header[1..].try_into().unwrap()))
 }
 
 fn read_block<R: std::io::Read>(reader: &mut R, block: &mut avro::Block) -> Result<(), Error> {