diff --git a/CHANGELOG.md b/CHANGELOG.md
index 8e050fcbf27..91b84631adf 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -84,6 +84,7 @@ Ansible Changes By Release
   * infini_host
   * infini_pool
   * infini_vol
+- logstash_plugin
 - omapi_host
 - openwrt_init
 - ovirt:
diff --git a/lib/ansible/modules/monitoring/logstash_plugin.py b/lib/ansible/modules/monitoring/logstash_plugin.py
new file mode 100644
index 00000000000..ba2b5a1aef1
--- /dev/null
+++ b/lib/ansible/modules/monitoring/logstash_plugin.py
@@ -0,0 +1,182 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+"""
+Ansible module to manage elasticsearch plugins
+(c) 2017, Loic Blot <loic.blot@unix-experience.fr>
+
+This file is part of Ansible
+
+Ansible is free software: you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+Ansible is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+GNU General Public License for more details.
+You should have received a copy of the GNU General Public License
+along with Ansible.  If not, see <http://www.gnu.org/licenses/>.
+"""
+
+ANSIBLE_METADATA = {'status': ['preview'],
+                    'supported_by': 'community',
+                    'version': '1.0'}
+
+DOCUMENTATION = '''
+---
+module: logstash_plugin
+short_description: Manage Logstash plugins
+description:
+    - Manages Logstash plugins.
+version_added: "2.3"
+author: Loic Blot (@nerzhul)
+options:
+    name:
+        description:
+            - Install plugin with that name.
+        required: True
+    state:
+        description:
+            - Apply plugin state.
+        required: False
+        choices: ["present", "absent"]
+        default: present
+    plugin_bin:
+        description:
+            - Specify logstash-plugin to use for plugin management.
+        required: False
+        default: /usr/share/logstash/bin/logstash-plugin
+    proxy_host:
+        description:
+            - Proxy host to use during plugin installation.
+        required: False
+        default: None
+    proxy_port:
+        description:
+            - Proxy port to use during plugin installation.
+        required: False
+        default: None
+    version:
+        description:
+            - Specify plugin Version of the plugin to install.
+              If plugin exists with previous version, it will NOT be updated.
+        required: False
+        default: None
+'''
+
+EXAMPLES = '''
+- name: Install Logstash beats input plugin
+  logstash_plugin:
+    state: present
+    name: logstash-input-beats
+
+- name: Install specific version of a plugin
+  logstash_plugin:
+    state: present
+    name: logstash-input-syslog
+    version: '3.2.0'
+
+- name: Uninstall Logstash plugin
+  logstash_plugin:
+    state: absent
+    name: logstash-filter-multiline
+'''
+
+PACKAGE_STATE_MAP = dict(
+    present="install",
+    absent="remove"
+)
+
+from ansible.module_utils.basic import AnsibleModule
+
+def is_plugin_present(module, plugin_bin, plugin_name):
+    cmd_args = [plugin_bin, "list", plugin_name]
+    rc, out, err = module.run_command(" ".join(cmd_args))
+    return rc == 0
+
+
+def parse_error(string):
+    reason = "reason: "
+    try:
+        return string[string.index(reason) + len(reason):].strip()
+    except ValueError:
+        return string
+
+
+def install_plugin(module, plugin_bin, plugin_name, version, proxy_host, proxy_port):
+    cmd_args = [plugin_bin, PACKAGE_STATE_MAP["present"], plugin_name]
+
+    if version:
+        cmd_args.append("--version %s" % version)
+
+    if proxy_host and proxy_port:
+        cmd_args.append("-DproxyHost=%s -DproxyPort=%s" % (proxy_host, proxy_port))
+
+    cmd = " ".join(cmd_args)
+
+    if module.check_mode:
+        rc, out, err = 0, "check mode", ""
+    else:
+        rc, out, err = module.run_command(cmd)
+
+    if rc != 0:
+        reason = parse_error(out)
+        module.fail_json(msg=reason)
+
+    return True, cmd, out, err
+
+
+def remove_plugin(module, plugin_bin, plugin_name):
+    cmd_args = [plugin_bin, PACKAGE_STATE_MAP["absent"], plugin_name]
+
+    cmd = " ".join(cmd_args)
+
+    if module.check_mode:
+        rc, out, err = 0, "check mode", ""
+    else:
+        rc, out, err = module.run_command(cmd)
+
+    if rc != 0:
+        reason = parse_error(out)
+        module.fail_json(msg=reason)
+
+    return True, cmd, out, err
+
+
+def main():
+    module = AnsibleModule(
+        argument_spec=dict(
+            name=dict(required=True),
+            state=dict(default="present", choices=PACKAGE_STATE_MAP.keys()),
+            plugin_bin=dict(default="/usr/share/logstash/bin/logstash-plugin", type="path"),
+            proxy_host=dict(default=None),
+            proxy_port=dict(default=None),
+            version=dict(default=None)
+        ),
+        supports_check_mode=True
+    )
+
+    name = module.params["name"]
+    state = module.params["state"]
+    plugin_bin = module.params["plugin_bin"]
+    proxy_host = module.params["proxy_host"]
+    proxy_port = module.params["proxy_port"]
+    version = module.params["version"]
+
+    present = is_plugin_present(module, plugin_bin, name)
+
+    # skip if the state is correct
+    if (present and state == "present") or (state == "absent" and not present):
+        module.exit_json(changed=False, name=name, state=state)
+
+    if state == "present":
+        changed, cmd, out, err = install_plugin(module, plugin_bin, name, version, proxy_host, proxy_port)
+    elif state == "absent":
+        changed, cmd, out, err = remove_plugin(module, plugin_bin, name)
+
+    module.exit_json(changed=changed, cmd=cmd, name=name, state=state, stdout=out, stderr=err)
+
+if __name__ == '__main__':
+    main()