Replies: 1 comment
-
I have found out myself now... You must not pass in a POSIX compatible unix timestamp, but a unix timestamp in milliseconds format. So |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Describe the bug
Hi All,
I am just getting started with RabbitMQ streams library. My implementation requires me to use the
OffsetTypeTimestamp
object. I pass in a posix timestamp e.g.1679909168
. However I always get messages at the start of the stream in return.Kind regards,
Reproduction steps
I specify my consumer like this:
IConsumer c = Stream.CreateRawConsumer( new RawConsumerConfig(streamName) { Reference = Guid.NewGuid().ToString(), OffsetSpec = new OffsetTypeTimestamp(FromTimestamp), MessageHandler = MessageReceived }, Logger).Result;
When receiving a message I check the
FromTimestamp
against the timestamp inside the message context and its completely different. It starts at the beginning of the stream.Expected behavior
I expect the
MessageContext.Timestamp.TotalSeconds
inside the MessageReceived despatcher to be bigger or (more or less equal) to my specified timestamp. However its days difference.Additional context
No response
Beta Was this translation helpful? Give feedback.
All reactions