HL7 v2 to Kafka producer
This project consist of a HL7v2 MLLP listener, which transfers received messages to a Kafka topic.
Messages are passed to a Kafka producer and send to a configured topic without any mapping. The sender receives an acknowledgement message (ACK) of each message sent.
The following environment variables can be set:
endpoint: kafka.topic: hl7-topic hl7: port: 2575 encoding: iso-8859-1
| Variable | Default | Description |
|---|---|---|
| KAFKA_BOOTSTRAP_SERVERS | localhost:9092 | Kafka brokers |
| KAFKA_SECURITY_PROTOCOL | PLAINTEXT | Kafka communication protocol |
| KAFKA_SSL_TRUST_STORE_PASSWORD | Truststore password (if using SECURITY_PROTOCOL=SSL) |
|
| KAFKA_SSL_KEY_STORE_PASSWORD | Keystore password (if using SECURITY_PROTOCOL=SSL) |
|
| ENDPOINT_KAFKA_TOPIC | hl7-topic | Kafka output topic to send HL7 messages to |
| ENDPOINT_HL7_PORT | 2575 | HL7 MLLP listener port |
| ENDPOINT_HL7_ENCODING | iso-8859-1 | Default encoding to use if not specified in the message header |
| LOG_LEVEL | info | Log level (error, warn, info, debug) |
Additional application properties can be set by overriding values form the application.yaml by using environment variables.
In general, the service expects incoming messages to conform to the HL7 2.x standard and the MLLP protocol.
In case of errors due to missing mandatory message header fields (id and
timestamp), formatting errors or unavailable Kafka broker connections (after
a timeout), an ACK message with the Application error type (AE) is returned.
A test setup and a script to send an example message is available for development purposes.
Available image tags can be found at the Container Registry or under Releases.