Try one off time based consumer

[deepredsky]

example

require 'time'
from = Time.parse('2023-05-25 13:55:08 +0200')
to = Time.parse('2023-05-25 13:55:10 +0200')

TimePeriodConsumer
  .new(brokers: ['localhost:9092'], group_id: 'test-ruby-group')
  .consume(topic: 'messages', from: from, to: to) do |msg|
    puts 'Received msg'
    pp msg
  end

[mensfeld]

FYI I am going to merge this karafka/rdkafka-ruby#229 into the next release (not the current 0.13.0 but next not to add complexity to the current changes in rdkafka)

[deepredsky]

FYI I am going to merge this appsignal/rdkafka-ruby#229 into the next release (not the current 0.13.0 but next not to add complexity to the current changes in rdkafka)

Thanks @mensfeld, i will test and experiment with this more when that feature is released