(iggy) branch fix_high_level_consumer_timestamp updated: fix(sdk): fix the high level consumer poll by timestamp

[gkoszyk]

This is an automated email from the ASF dual-hosted git repository.

gkoszyk pushed a commit to branch fix_high_level_consumer_timestamp
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to 
refs/heads/fix_high_level_consumer_timestamp by this push:
     new c62e06eef fix(sdk): fix the high level consumer poll by timestamp
c62e06eef is described below

commit c62e06eef99db463e5c3fe0a107c8b82da8b6a2f
Author: numinex <g.koszy...@gmail.com>
AuthorDate: Wed Dec 17 18:27:39 2025 +0100

    fix(sdk): fix the high level consumer poll by timestamp
---
 core/sdk/src/clients/consumer.rs | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/core/sdk/src/clients/consumer.rs b/core/sdk/src/clients/consumer.rs
index 0760d3f8a..71bd6286a 100644
--- a/core/sdk/src/clients/consumer.rs
+++ b/core/sdk/src/clients/consumer.rs
@@ -923,8 +923,15 @@ impl Stream for IggyConsumer {
             }
 
             if self.buffered_messages.is_empty() {
-                if self.polling_strategy.kind == PollingKind::Offset {
-                    self.polling_strategy = 
PollingStrategy::offset(message.header.offset + 1);
+                match self.polling_strategy.kind {
+                    PollingKind::Offset => {
+                        self.polling_strategy = 
PollingStrategy::offset(message.header.offset + 1);
+                    }
+                    PollingKind::Timestamp => {
+                        self.polling_strategy =
+                            
PollingStrategy::timestamp(message.header.timestamp.into());
+                    }
+                    _ => {}
                 }
 
                 if self.store_offset_after_all_messages {