Contents

module NulogyMessageBusConsumer
  module Steps
    class SeekBeginningOfTopic
      def call(kafka_consumer:, **_)
        KafkaUtils.seek_beginning(kafka_consumer)
        yield
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
nulogy_message_bus_consumer-3.0.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-2.0.1	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-2.0.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-1.0.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.5.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-1.0.0.alpha	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.4.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.3.3	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.3.2	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.3.1	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.3.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb
nulogy_message_bus_consumer-0.2.0	lib/nulogy_message_bus_consumer/steps/seek_beginning_of_topic.rb