lib/mimi/messaging/kafka/adapter.rb
# Delivers a message to a given topic.
#
# The topic will NOT be created if it does not exist.
#
# NOTE: the kafka broker may still automatically create a topic
#
Delivers a message to a given topic.
The topic will NOT be created if it does not exist.

the kafka broker may still automatically create a topic
Delivers a message to a given topic . The topic will NOT be created if it does not exist . the kafka broker may still automatically create a topic
def deliver_message(message, kafka_topic, headers = {})
          @connection_mutex.synchronize do
            connection.deliver_message(message, topic: kafka_topic, headers: headers)
          end
        rescue StandardError => e
          logger&.warn "Failed to deliver message to '#{kafka_topic}': #{e}"
        end
def deliver_message ( message , kafka_topic , headers = { } ) @connection_mutex . synchronize do connection . deliver_message ( message , topic : kafka_topic , headers : headers ) end rescue StandardError => e logger &. warn "Failed to deliver message to '#{kafka_topic}': #{e}" end
Delivers a message to a given topic.
Delivers a message to a given topic .
message
<not_specific>
kafka_topic
<not_specific>
headers
<not_specific>