Kafka publisher

publisher.ex

defmodule Sample.Publisher do
  
  def publish(event_name, payload, context \\ %{}, topic \\ :default) do
    
    message_body = %{
      payload: payload,
      meta: event_metadata(event_name, context)
    }
    
    KaufmannEx.Publisher.publish(event_name, message_body, context)
  end  
  
  def event_metadata(event_name, context) do
  end
  
end