[KAFKA-2375] Implement elasticsearch Copycat sink connector

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Component/s: connect
• Assignee: Liquan Pei
• Reporter: Ewen Cheslack-Postava
• Reviewer: Ewen Cheslack-Postava
• Created: 27/Jul/15 06:20
• Updated: 14/May/16 08:10
• Resolved: 03/Mar/16 06:33

Description

Implement an elasticsearch sink connector for Copycat. This should send records to elasticsearch with unique document IDs, given appropriate configs to extract IDs from input records.

The motivation here is to provide a good end-to-end example with built-in connectors that require minimal dependencies. Because Elasticsearch has a very simple REST API, an elasticsearch connector shouldn't require any extra dependencies and logs -> Elasticsearch (in combination with KAFKA-2374) provides a compelling out-of-the-box Copycat use case.