[
https://issues.apache.org/jira/browse/NIFI-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15081586#comment-15081586
]
Ricky Saltzer commented on NIFI-1337:
-------------------------------------
Since the bulletin repository is exposed within the reporting task context, I
decided to make it optional to forward bulletin messages to Riemann. I think
this could be useful when creating alerts when specific log level messages are
emitted from a certain processor. Just like the other types of events, you can
disable forwarding bulletin messages to Riemann if you desire. You may also
filter out bulletin messages based on log level severity.
Here is an example Riemann event:
{code}
time: 1451932526541
state: "ERROR"
service: "nifi-test.bulletin.PROCESSOR.cd34a606-fc34-48e4-8091-deed35988bf4.167"
host: "172.23.2.144"
description: "ERROR : PutFile[id=cd34a606-fc34-48e4-8091-deed35988bf4]
Penalizing
StandardFlowFileRecord[uuid=a8c92dee-4156-46eb-ba37-115b1aea6ee9,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1451932526460-1, container=default,
section=1], offset=20480,
length=10240],offset=0,name=1991306385994038,size=10240] and routing to
\'failure\' because the output directory /tmp/ffs does not exist and Processor
is configured not to create missing directories"
tags: "nifi"
ttl: 60.0
{code}
Keeping track of the {{max}} ID from the bulletins returned ensures we avoid
sending duplicate messages to Riemann.
> Add Riemann Reporting Task
> --------------------------
>
> Key: NIFI-1337
> URL: https://issues.apache.org/jira/browse/NIFI-1337
> Project: Apache NiFi
> Issue Type: New Feature
> Reporter: Ricky Saltzer
> Assignee: Ricky Saltzer
> Attachments: example-graph.png, riemann-reporting-configuration.png
>
>
> It would be beneficial for NiFi to report health information to
> [Riemann|http://riemann.io] for monitoring purposes. I plan on implementing
> this, and will use this JIRA to track the progress.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
