bzkf / obds-to-fhir

This project contains a Kafka Stream processor that creates FHIR resources from oBDS-XML data and writes them to a FHIR Topic.
GNU General Public License v3.0
3 stars 1 forks source link

Refactor string-STRUCT zu tatsächlichem Kafka Struct/JSON key #73

Open chgl opened 2 months ago

chgl commented 2 months ago

In https://github.com/bzkf/obds-to-fhir/blob/master/src/main/java/org/miracum/streams/ume/obdstofhir/processor/ObdsProcessor.java#L80-L84 erzeugen wir aktuell ein struct-aussehenden string, man könnte es noch "schöner" refactoren indem man ein tatsächliches Kafka struct für den key nutzt (https://kafka.apache.org/38/javadoc/org/apache/kafka/connect/data/Struct.html) oder auch zB JSON als key.

Nicht vergessen den KeySerializer entsprechend anzupassen.

Technisch gesehen wäre das ein breaking change der zumindest erforderlich machen würde bisherige Topics neu zu befüllen.