Class: CC::Kafka::Producer::Poseidon

Inherits:
Object
  • Object
show all
Defined in:
lib/cc/kafka/producer/poseidon.rb

Instance Method Summary collapse

Constructor Details

#initialize(host, port, topic, client_id) ⇒ Poseidon

Returns a new instance of Poseidon.



7
8
9
10
11
 
# File 'lib/cc/kafka/producer/poseidon.rb', line 7

def initialize(host, port, topic, client_id)
  @brokers = ["#{host}:#{port}"]
  @topic = topic
  @client_id = client_id
end

Instance Method Details

#close ⇒ Object 



20
21
22
 
# File 'lib/cc/kafka/producer/poseidon.rb', line 20

def close
  producer.close
end

#send_message(message, key) ⇒ Object 



13
14
15
16
17
18
 
# File 'lib/cc/kafka/producer/poseidon.rb', line 13

def send_message(message, key)
  Kafka.logger.debug("sending message direct via Poseidon")
  producer.send_messages([
    ::Poseidon::MessageToSend.new(@topic, message, key)
  ])
end