java.lang.Object
- org.linuxforhealth.fhir.persistence.index.FHIRRemoteIndexService
- - org.linuxforhealth.fhir.server.index.kafka.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

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> java.util.concurrent.CompletableFuture<T>`	`backToThe(java.util.concurrent.Future<T> f)`	Convert a Future into a CompletableFuture
`void`	`init(KafkaPropertyAdapter properties)`	Initialize the provider
`void`	`shutdown()`	Performs any necessary "shutdown" logic to disconnect from the topic.
`IndexProviderResponse`	`submit(RemoteIndexData data)`	Submit the index data request to the async indexing service we represent

Methods inherited from class org.linuxforhealth.fhir.persistence.index.FHIRRemoteIndexService
getServiceInstance, setServiceInstance

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Class FHIRRemoteIndexKafkaService