(streampipes) branch 3355-add-new-avro-format-parser updated: Improve avro parse exception

[oehler]

This is an automated email from the ASF dual-hosted git repository.

oehler pushed a commit to branch 3355-add-new-avro-format-parser
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/3355-add-new-avro-format-parser by this push:
     new 442eb31845 Improve avro parse exception
442eb31845 is described below

commit 442eb31845efe1674f5207a8aa1d65d1c9b7c946
Author: Sven Oehler <oehler.s...@web.de>
AuthorDate: Tue Nov 26 17:40:06 2024 +0100

    Improve avro parse exception
---
 .../extensions/management/connect/adapter/parser/AvroParser.java    | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/AvroParser.java
 
b/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/AvroParser.java
index c1c8b8f57c..653a8ab40a 100644
--- 
a/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/AvroParser.java
+++ 
b/streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/AvroParser.java
@@ -140,12 +140,10 @@ public class AvroParser implements IParser {
         inputStream.skipNBytes(5);
       }
       BinaryDecoder decoder = DecoderFactory.get().binaryDecoder(inputStream, 
null);
-      GenericRecord avroRecord = datumReader.read(null, decoder);
-      LOG.info("Read record: {}", avroRecord);
-      return  avroRecord;
+      return datumReader.read(null, decoder);
     } catch (IOException e) {
       throw new ParseException(
-          "Error processing Kafka message: " + e.getMessage()
+          "Error decoding the avro message. Please check the schema."
       );
     }
   }