Rajesh Sharma

Try one off time based consumer

2

example ```ruby 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'...

Globally configured partitioner is not being correctly passed on to the internal rdkafka producer in the new standalone Racecar producer. This patch fixes this issue This config was added to...

experiments with rdkafka

Migrate to rdkafka-ruby

2

- Test inspect the internal state - Consumer starting point offset doesn't seem to work yet - Need to split sync/async again to manage batching delay