kafka_handler.rb

#!/opt/sensu/embedded/bin/ruby
require 'sensu-handler'
require 'kafka'

class Show < Sensu::Handler
  def handle
    kafka = Kafka.new(
    # At least one of these nodes must be available:
    seed_brokers: ["x.x.x.x:9092"],
    # Set an optional client id in order to identify the client to Kafka:
    client_id: "my-test",
    )
 # Instantiate a new producer.
    producer = kafka.producer
    # Add a message to the producer buffer.
    producer.produce(@event.inspect, topic: "test")
    # Deliver the messages to Kafka.
    producer.deliver_messages
  end
end