Background:
I’ve been using a named Tailer to read messages from ChronicleQueue and track offsets. My current setup handles individual messages and keeps track of where we left off between restarts like this: