Github user joewitt commented on a diff in the pull request:
https://github.com/apache/nifi/pull/1695#discussion_r114149213
--- Diff:
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_0_10.java
---
@@ -160,6 +163,11 @@
.name("success")
.description("FlowFiles received from Kafka. Depending on
demarcation strategy it is a flow file per message or a bundle of messages
grouped by topic and partition.")
.build();
+ static final Relationship REL_PARSE_FAILURE = new
Relationship.Builder()
--- End diff --
@markap14 this is good but i think we'll need the metadata
(topic,partition,offset) as that would obviously be helpful to folks
troubleshooting such issues.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---