| # Camel-Kafka-connector FHIR Source Example |
| |
| ## Introduction |
| |
| This is an example for Camel-Kafka-connector |
| |
| ## What is needed |
| |
| - A Kafka Cluster running |
| |
| ## Running Kafka |
| |
| ``` |
| $KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties |
| $KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties |
| $KAFKA_HOME/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic patients |
| ``` |
| |
| |
| ## Setting up the needed bits and running the example |
| |
| You'll need to setup the plugin.path property in your kafka |
| |
| Open the `$KAFKA_HOME/config/connect-standalone.properties` |
| |
| and set the `plugin.path` property to your choosen location |
| |
| In this example we'll use `/home/ldemasi/connectors/` |
| |
| ``` |
| > mkdir -p /home/ldemasi/connectors/ && cd /home/ldemasi/connectors/ |
| > wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-fhir-kafka-connector/0.11.5/camel-fhir-kafka-connector-0.11.5-package.tar.gz |
| > untar.gz camel-fhir-kafka-connector-0.11.5-package.tar.gz |
| ``` |
| |
| Now you can run the example |
| |
| ``` |
| $KAFKA_HOME/bin/connect-standalone.sh $KAFKA_HOME/config/connect-standalone.properties source/CamelFhirSourceConnector.properties |
| ``` |
| |
| Just connect to your Kafka and check with the kafka console consumer that the messages are available in the kafka topic. |
| ```bash |
| $KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic mytopic --from-beginning |
| { |
| "resourceType": "Bundle", |
| "id": "80a62211-eb26-412c-9ebc-f39bc1f1dff7", |
| "meta": { |
| "lastUpdated": "2021-02-10T14:22:46.149+00:00" |
| }, |
| "type": "searchset", |
| "link": [ |
| { |
| "relation": "self", |
| "url": "http://hapi.fhir.org/baseR4/Patient?_pretty=true" |
| }, |
| { |
| "relation": "next", |
| "url": "http://hapi.fhir.org/baseR4?_getpages=80a62211-eb26-412c-9ebc-f39bc1f1dff7&_getpagesoffset=20&_count=20&_pretty=true&_bundletype=searchset" |
| } |
| ], |
| "entry": [ |
| { |
| "fullUrl": "http://hapi.fhir.org/baseR4/Patient/628467", |
| "resource": { |
| "resourceType": "Patient", |
| "id": "628467", |
| ......... |
| |
| Ctrl+C |
| ``` |