group :test do
  gem 'testcontainers-kafka'
end

require "testcontainers/kafka"
require "rdkafka"

container = Testcontainers::KafkaContainer.new.start

begin
  container.wait_for_tcp_port(9092)
  config = {
    "bootstrap.servers": container.connection_url,
    "group.id": "ruby-example",
    "auto.offset.reset": "earliest"
  }

  producer = Rdkafka::Config.new(config).producer
  producer.produce(payload: "hello", topic: "example").wait

  consumer = Rdkafka::Config.new(config).consumer
  consumer.subscribe("example")
  puts consumer.each { |msg| break msg.payload }
ensure
  container.stop if container.running?
  container.remove if container.exists?
end