This is a tracking issue for the in-progress MQTT input .

Pending requirements:

• Initial draft checkin (Add MQTT input to Filebeat #15287)
• Reconnection after errors (MQTT: Establish new connection after error and clean shutdown #15982)
• Clean shutdown / reliable Stop and Wait (MQTT: Establish new connection after error and clean shutdown #15982)
• Ack handling ([Filebeat] MQTT input: Implement end-to-end ACK #15610)
  • (Need more background here, it's not clear to me yet if / how we need to handle this)
• Documentation (for all new config fields and emitted event fields) (MQTT: Write input documentation #16126)
• Tests
  • Unit tests (MQTT: Establish new connection after error and clean shutdown #15982)
    • code that translates configuration + raw MQTT input to beats events should be refactored into a standalone function and unit tested.
  • System tests (MQTT: Add integration test #16125)
    • bring up the input with a live connection to localhost and pass it test events. This is usually done in the python tests, but if we can get good coverage in go instead I'd be happy (that usually makes verification simpler since you can pass in a mocked outlet for outgoing events instead of requiring a real backend index, but if library support or other context makes it easier in python then that's fine).
• Merge to master and update changelog (Filebeat: Merge "mqtt" input to master #16204)