Initial topic message sometimes not delivered

[steven-sheehy]

Description

The ConsensusService.subscribeTopic() gRPC API can sometimes fail to deliver the initial message upon subscription due to a race condition when transitioning from historical to live streaming.

Steps to reproduce

Run acceptance test in CI. Here's an example: https://github.com/hiero-ledger/hiero-mirror-node/actions/runs/17270892681/job/49015064782?pr=11761

Additional context

    2025-08-27T15:28:05.565Z  INFO ForkJoinPool-1-worker-1 o.h.m.t.e.a.c.StartupProbe Creating a topic to confirm node connectivity
    2025-08-27T15:28:06.173Z  INFO ForkJoinPool-1-worker-1 o.h.m.t.e.a.c.StartupProbe Created topic 0.0.1002 successfully
    2025-08-27T15:28:06.693Z  INFO ForkJoinPool-1-worker-1 o.h.m.t.e.a.c.MirrorNodeClient GET http://mirror-rest/api/v1/transactions/0.0.2-1756308475-587000483: 200 OK
    2025-08-27T15:28:06.693Z  INFO ForkJoinPool-1-worker-1 o.h.m.t.e.a.c.StartupProbe Subscribing to topic 0.0.1002
    2025-08-27T15:28:06.698Z  INFO ForkJoinPool-1-worker-1 o.h.m.t.e.a.c.StartupProbe Submitting a message to the network
    2025-08-27T15:28:06.949Z  INFO grpc-executor-1 o.h.m.g.s.TopicMessageServiceImpl Subscribing to topic: TopicMessageFilter(endTime=null, limit=0, startTime=0, subscriberId=X1YNDEEq, topicId=0.0.1002)
    2025-08-27T15:28:06.961Z  INFO ForkJoinPool-1-worker-1 o.h.m.t.e.a.c.StartupProbe Waiting for the mirror node to publish the topic message
    2025-08-27T15:28:07.666Z  INFO grpc-executor-1 o.h.m.g.r.PollingTopicMessageRetriever [X1YNDEEq] Finished retrieving 0 messages in 713.5 ms (0/s)
    2025-08-27T15:28:07.678Z  INFO grpc-executor-1 o.h.m.g.l.RedisTopicListener Subscribing: TopicMessageFilter(endTime=null, limit=0, startTime=0, subscriberId=X1YNDEEq, topicId=0.0.1002)
    2025-08-27T15:28:07.679Z  INFO grpc-executor-1 o.h.m.g.l.RedisTopicListener Creating shared subscription to topic.1002
    2025-08-27T15:28:07.680Z  INFO grpc-executor-1 o.h.m.g.l.RedisTopicListener Attempting to connect to Redis
    2025-08-27T15:28:07.681Z  INFO grpc-executor-1 o.h.m.g.l.RedisTopicListener Connected to Redis

Hedera network

other

Version

v0.137.0

Operating system

None