Github user trixpan commented on the issue:
https://github.com/apache/nifi/pull/1418
@mattyb149 - this isn't ready yet but I suspect it may be functional. So
far I have been testing with filebeat but it should work with metricbeat as
well.
Of note:
- the processor performs partial ACKs, more precisely it replies to EVERY
sequence number with an ACK, completely ignoring the window size. This may
change prior to merging.
- Given ListenLumberjack has been my first attempt in coding, while
migrating from ListenLumberjack to ListenBeats I tried to clean the code a bit,
I think there still space for improvement.
To test the processor all it is needed is to:
1. Download filebeat and unzip it
2. use the following config:
```
filebeat.prospectors:
- input_type: log
paths:
- logsource/*.log
output.logstash:
hosts: ["localhost:5044"]
compression_level: 0
timeout: 600
bulk_max_size: 1
```
---
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.
---
