configuration.rb in deimos-ruby-1.20.0

- old
+ new

@@ -451,11 +451,11 @@
 
     setting_object :db_poller do
       # Mode to use for querying - :time_based (via updated_at) or :state_based.
       setting :mode, :time_based
       # Producer class to use for the poller.
-      setting :producer_class
+      setting :producer_class, nil
       # How often to run the poller, in seconds. If the poll takes longer than this
       # time, it will run again immediately and the timeout
       # will be pushed to the next e.g. 1 minute.
       setting :run_every, 60
       # The number of times to retry production when encountering a *non-Kafka* error.
@@ -479,9 +479,12 @@
       setting :publish_timestamp_column
       # Value to set the state_column to once published - state-based only.
       setting :published_state
       # Value to set the state_column to if publishing fails - state-based only.
       setting :failed_state
+
+      # Inherited poller class name to use for publishing to multiple kafka topics from a single poller
+      setting :poller_class, nil
     end
 
     deprecate 'kafka_logger', 'kafka.logger'
     deprecate 'reraise_consumer_errors', 'consumers.reraise_errors'
     deprecate 'schema_registry_url', 'schema.registry_url'