Class FHIRRemoteIndexKafkaService


  • public class FHIRRemoteIndexKafkaService
    extends FHIRRemoteIndexService
    Forwards parameter blocks to a partitioned Kafka topic. This allows us to skip the expensive parameter insert operations during ingestion and offload them to a separate process where we can process the operations more efficiently by using larger batches and different concurrency control mechanisms
    • Constructor Detail

      • FHIRRemoteIndexKafkaService

        public FHIRRemoteIndexKafkaService()
        Default constructor
    • Method Detail

      • init

        public void init​(KafkaPropertyAdapter properties)
        Initialize the provider
        Parameters:
        properties -
      • shutdown

        public void shutdown()
        Performs any necessary "shutdown" logic to disconnect from the topic.
      • backToThe

        public static <T> java.util.concurrent.CompletableFuture<T> backToThe​(java.util.concurrent.Future<T> f)
        Convert a Future into a CompletableFuture
        Type Parameters:
        T -
        Parameters:
        f -
        Returns: