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

Kafka Connect. Add map entry value extraction SMT

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 2.4.0
    • Fix Version/s: None
    • Component/s: KafkaConnect
    • Labels:
      None

      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

            Activity

              People

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

                Dates

                • Created:
                  Updated: