bisect-ruby-kafka.rb

require "bundler/setup"
require "kafka"

def foo(msg)
  puts "=="*50
  kafka = Kafka.new(
    seed_brokers: ["shopify.railgun:9092"],
    client_id: "flow_rails_whatever",
    logger: Logger.new(STDOUT)
  )

  producer = kafka.producer

  producer.produce( msg, topic: "flow_runs")
  producer.deliver_messages
rescue => _
end

# corrupted
puts ">> corrupted"
msg = "1" * 32760
foo(msg)
puts "<<"*20

# not corrupted
puts ">> not corrupted"
msg = "1" * 32759
foo(msg)
puts "<<"*20