Module: Deimos::KafkaSource::ClassMethods

Defined in:
lib/deimos/kafka_source.rb,
sig/defs.rbs

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

#kafka_config ⇒ Hash

Returns:

  • (Hash) 


71
72
73
74
75
76
77
78
 
# File 'lib/deimos/kafka_source.rb', line 71

def kafka_config
  {
    update: true,
    delete: true,
    import: true,
    create: true
  }
end

#kafka_producers ⇒ ::Array[Deimos::ActiveRecordProducer]

@return — the producers to run.

Returns:



81
82
83
 
# File 'lib/deimos/kafka_source.rb', line 81

def kafka_producers
  raise MissingImplementationError
end