Example Ruby Kafka client API

kafka_consumer.rb

require 'kafka'

kafka_brokers = ENV.fetch("KAFKA_BROKERS").split(",")
kafka_topic = "application.events"

kafka = Kafka.new(brokers: kafka_brokers, logger: logger)

consumer = kafka.consumer(group_id: "my-consumer", autocommit: true)

consumer.subscribe(kafka_topic) do |messages|
  messages.each do |message|
    puts message.topic, message.partition, message.offset, message.key, message.value
  end
end