Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9318

Kafka Connect. Add map entry value extraction SMT

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 2.4.0
    • None
    • connect

    Description

      Currently there is ExtractField SMT available that makes it possible to pull specific field from generic JSON or Connect Struct. When Connect Struct with a map field is used this approach does not work when given map entry has to be extracted.

      Example case: JMS source imports message that has entity correlation key inside message property. We want to use the same key for Kafka messages.

      Currently it requires custom SMT coding, while the logic is generic.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #7856

          Activity

            People

              Unassigned Unassigned
              psmolinski Piotr Smolinski
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: