Module: Deimos::KafkaSource::ClassMethods

Defined in:
lib/deimos/kafka_source.rb

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

#kafka_config ⇒ Hash

Returns:

  • (Hash) 


63
64
65
66
67
68
69
70
 
# File 'lib/deimos/kafka_source.rb', line 63

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

#kafka_producers ⇒ Array<Deimos::ActiveRecordProducer>

Returns the producers to run.

Returns:

Raises:

  • (NotImplementedError) 


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

def kafka_producers
  if self.respond_to?(:kafka_producer)
    Deimos.config.logger.warn(message: DEPRECATION_WARNING)
    return [self.kafka_producer]
  end

  raise NotImplementedError
end