Skip to content

Instantly share code, notes, and snippets.

@armando-couto

armando-couto/kafka.rb

Last active May 30, 2023 03:51
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save armando-couto/966a3abd18b0c864aa79a94f269d12f3 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save armando-couto/966a3abd18b0c864aa79a94f269d12f3 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. armando-couto revised this gist May 30, 2023. No changes.
  2. armando-couto created this gist May 30, 2023.
    32 changes: 32 additions & 0 deletions kafka.rb
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,32 @@
    require 'kafka'

    # Set up Kafka client
    kafka = Kafka.new(
    seed_brokers: ['localhost:9092'],
    client_id: 'my_kafka_client'
    )

    # Create a producer
    producer = kafka.producer

    # Create a consumer
    consumer = kafka.consumer(group_id: 'my_consumer_group')

    # Define the topic
    topic = 'my_topic'

    # Publish messages to Kafka
    producer.produce('Hello, Kafka!', topic: topic)
    producer.deliver_messages

    # Subscribe to the topic and consume messages
    consumer.subscribe(topic)

    # Start consuming messages
    consumer.each_message do |message|
    puts "Received message: #{message.value}"
    end

    # Close connections
    producer.shutdown
    consumer.stop