(nifi) branch main updated: NIFI-14756 Added debug log for Record Parsing Failures to ConsumeKafka (#10100)

[exceptionfactory]

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

exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 1457950040 NIFI-14756 Added debug log for Record Parsing Failures to 
ConsumeKafka (#10100)
1457950040 is described below

commit 1457950040d0fe86ade53770def6c5a95b6f0252
Author: Alaksiej Ščarbaty <65507498+awell...@users.noreply.github.com>
AuthorDate: Fri Jul 18 19:11:02 2025 +0200

    NIFI-14756 Added debug log for Record Parsing Failures to ConsumeKafka 
(#10100)
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../consumer/convert/AbstractRecordStreamKafkaMessageConverter.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/consumer/convert/AbstractRecordStreamKafkaMessageConverter.java
 
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/consumer/convert/AbstractRecordStreamKafkaMessageConverter.java
index 50c5f30bdf..199881e5ad 100644
--- 
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/consumer/convert/AbstractRecordStreamKafkaMessageConverter.java
+++ 
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/consumer/convert/AbstractRecordStreamKafkaMessageConverter.java
@@ -110,6 +110,8 @@ public abstract class 
AbstractRecordStreamKafkaMessageConverter implements Kafka
                     processSingleRecord(session, recordGroups, consumerRecord, 
record, attributes, extraAttrs, topic, partition);
                 }
             } catch (final MalformedRecordException | IOException | 
SchemaNotFoundException e) {
+                logger.debug("Reader or Writer failed to process Kafka Record 
with Topic [{}] Partition [{}] Offset [{}]",
+                             consumerRecord.getTopic(), 
consumerRecord.getPartition(), consumerRecord.getOffset(), e);
                 handleParseFailure(session, consumerRecord, attributes, value);
                 offsetTracker.update(consumerRecord);
                 continue;