Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2365 Copycat checklist
  3. KAFKA-2375

Implement elasticsearch Copycat sink connector

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: KafkaConnect
    • Labels:
      None

      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.

        Attachments

          Activity

            People

            • Assignee:
              liquanpei Liquan Pei
              Reporter:
              ewencp Ewen Cheslack-Postava
              Reviewer:
              Ewen Cheslack-Postava
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: