@@ -58,7 +58,7 @@ protected <T> T deserializeObject(byte[] data, Class<T> type, SchemaRegistryTyp
5858
5959 private <T > T defaultDeserializer (byte [] data , Class <T > type ) throws IOException {
6060 try {
61- LOGGER .info ("Using default Protobuf deserializer" );
61+ LOGGER .debug ("Using default Protobuf deserializer" );
6262 Parser <Message > parser = (Parser <Message >) type .getMethod ("parser" ).invoke (null );
6363 Message message = parser .parseFrom (data );
6464 return type .cast (message );
@@ -70,13 +70,12 @@ private <T> T defaultDeserializer(byte[] data, Class<T> type) throws IOException
7070 private <T > T confluentDeserializer (byte [] data , Class <T > type ) throws IOException {
7171 try {
7272
73- LOGGER .info ("Using confluentDeserializer " );
73+ LOGGER .debug ("Using Confluent Deserializer " );
7474 Parser <Message > parser = (Parser <Message >) type .getMethod ("parser" ).invoke (null );
7575 ByteBuffer buffer = ByteBuffer .wrap (data );
7676 int size = ByteUtils .readVarint (buffer );
7777
7878 // Only if the size is greater than zero, continue reading varInt. based on Glue Proto deserializer implementation
79- // Ref: https://tiny.amazon.com/1ru6rz8z/codeamazpackMaveblob1963thir
8079 if (size > 0 ) {
8180 for (int i = 0 ; i < size ; i ++) {
8281 ByteUtils .readVarint (buffer );
@@ -93,12 +92,11 @@ private <T> T confluentDeserializer(byte[] data, Class<T> type) throws IOExcepti
9392 private <T > T glueDeserializer (byte [] data , Class <T > type ) throws IOException {
9493 try {
9594
96- LOGGER .info ("Using glueDeserializer " );
95+ LOGGER .debug ("Using Glue Deserializer " );
9796 CodedInputStream codedInputStream = CodedInputStream .newInstance (data );
9897 Parser <Message > parser = (Parser <Message >) type .getMethod ("parser" ).invoke (null );
9998
10099 // Seek one byte forward. Based on Glue Proto deserializer implementation
101- // Ref: https://tiny.amazon.com/1c9cadl8g/codeamazpackMaveblobcf94thir
102100 codedInputStream .readUInt32 ();
103101
104102 Message message = parser .parseFrom (codedInputStream );
0 commit comments