Help retrieve events and current state for a specific aggregate from Axon Server

mandoolala · July 17, 2025, 8:29am

Hi,

We need help on implementing our own event store inspection service for retrieving aggregate’s events and current state.

We can’t rely on axonserver dashboard Event Store > Search built-in utility for various reasons.

We want to expose this specific functionality in our back office admin tool for our production operation team’s use.
We want to enable listing of each aggregate’s event payloads by sequence order in a single view, whereas the current axonserver dashboard only allows the user to view each event detail at once.

We also want to retrieve the current (latest) state by replaying the events, instead of the entry from its read-side repository resulting from projection. How can I achieve this?

We’ve discovered:

Axon Server Integration API /v2/aggregates/{aggregateId}/events does not return proper payload
Axon Server Integration API

“payload”: “eyJjb21wYW55Ijp…”

Using grpc

import io.axoniq.axonserver.grpc.event.GetAggregateEventsRequest

github.com/AxonIQ/axon-server-se

axonserver/src/main/java/io/axoniq/axonserver/grpc/EventStoreService.java

0c17f393f


      
          package io.axoniq.axonserver.grpc;
          
          import io.axoniq.axonserver.AxonServerAccessController;
          import io.axoniq.axonserver.config.AuthenticationProvider;
          import io.axoniq.axonserver.exception.ErrorCode;
          import io.axoniq.axonserver.exception.ExceptionUtils;
          import io.axoniq.axonserver.exception.MessagingPlatformException;
          import io.axoniq.axonserver.grpc.event.Confirmation;
          import io.axoniq.axonserver.grpc.event.Event;
          import io.axoniq.axonserver.grpc.event.EventStoreGrpc;
          import io.axoniq.axonserver.grpc.event.GetAggregateEventsRequest;
          import io.axoniq.axonserver.grpc.event.GetAggregateSnapshotsRequest;
          import io.axoniq.axonserver.grpc.event.GetEventsRequest;
          import io.axoniq.axonserver.grpc.event.GetFirstTokenRequest;
          import io.axoniq.axonserver.grpc.event.GetLastTokenRequest;
          import io.axoniq.axonserver.grpc.event.GetTokenAtRequest;
          import io.axoniq.axonserver.grpc.event.QueryEventsRequest;
          import io.axoniq.axonserver.grpc.event.QueryEventsResponse;
          import io.axoniq.axonserver.grpc.event.ReadHighestSequenceNrRequest;
          import io.axoniq.axonserver.grpc.event.ReadHighestSequenceNrResponse;
          import io.axoniq.axonserver.grpc.event.TrackingToken;

Please help!