[GitHub] nifi issue #1418: NIFI-3238 - Introduce ListenBeats processor and deprecates...

[trixpan <gi...@git.apache.org>]

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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---