Load FHIR🔥 bundles from a Kafka topic into a FHIR server
Consumers can filter incoming messages by date properties of FHIR resources if a filter.value
is configured with a yyyy-mm-dd layout (see configuration properties).
If a filter expression matches at least one resource, the complete bundle will be processed. Filters apply to the following date properties:
| Property | Type | Example resource types |
|---|---|---|
effectiveDateTime |
dateTime | Observation |
performedDateTime |
dateTime | Procedure |
recordedDate |
dateTime | Condition |
authoredOn |
dateTime | DiagnosticReport |
effectivePeriod |
Period | Observation |
period |
Period | Encounter |
Additionally, the following filter.comparator values are supported: >,>=,<,<= and =.
Empty or missing comparator values default to =, which compares only the date part of properties.
⚠️ NOTE Patient resources will never be subject to filter rules and are always processed.
In order to enable Multi-threaded message consumption one consumer per input topic is used. Multiple consumers per topic are currently not supported.
By default, the consumers are configured to auto-commit offsets, in order to improve performance.
However, the latest successfully processed messages (i.e. send to the FHIR server) per topic are committed manually on shutdown (interrupt or kill). This ensures that offsets reflect successfully processed messages only.
The HTTP client supports retrying requests to the FHIR server in case the target endpoint is unavailable or runs into a timeout. See configuration properties below.
FHIR resource types are currently not validated. Processing requires only valid JSON content.
| Name | Default | Description |
|---|---|---|
app.name |
fhir-to-server | Kafka consumer group id |
app.log-level |
info | Log level (error,warn,info,debug,trace) |
app.env |
production | Environment mode (production, development) |
kafka.bootstrap-servers |
localhost:9092 | Kafka brokers |
kafka.security-protocol |
ssl | Kafka communication protocol |
kafka.input-topic |
Kafka topic to consume | |
kafka.ssl.ca-location |
/app/cert/kafka-ca.pem | Kafka CA certificate location |
kafka.ssl.certificate-location |
/app/cert/app-cert.pem | Client certificate location |
kafka.ssl.key-location |
/app/cert/app-key.pem | Client key location |
kafka.ssl.key-password |
Client key password | |
fhir.server.base-url |
http://localhost:8080/fhir | FHIR server base URL |
fhir.server.auth.user |
FHIR server BasicAuth username | |
fhir.server.auth.password |
FHIR server BasicAuth password | |
fhir.retry.count |
10 | Retry count |
fhir.retry.timeout |
10 | Retry timeout |
fhir.retry.wait |
5 | Retry wait between retries |
fhir.retry.max-wait |
20 | Retry maximum wait |
fhir.filter.date.value |
Date with format yyyy-mm-dd |
|
fhir.filter.date.comparator |
One of: >,>=,<,<=,= |
Override configuration properties by providing environment variables with their respective names.
Upper case env variables are supported as well as underscores (_) instead of . and -.