Detailed Information

The jEAP OpenSearch Index Writer Service bridges Kafka event streams and OpenSearch indices using a declarative message configuration. Each message binds an event type and topic to one or more operations, where each operation defines an index type, an index operation (UPSERT or DELETE), a SearchItem Provider URI, and a reference provider that extracts the business object reference (OriginType, Id, optional Version) from the event. Operations can be guarded by conditions and feature flags, ensuring that indexing only occurs when relevant. Before writing, the service validates that the SearchItem returned by the provider is compatible with the target IndexType definition. The service manages search item timestamps and minor version automatically, and always writes via the IndexWriteAlias to support platform-managed index rotation. On startup, the service validates index mappings against the IndexType definitions, applying compatible updates automatically and refusing to start when an incompatible deviation is detected. Failed index operations are forwarded to the jEAP error handling service to ensure no event is lost.