Sha256: 2a796511dac86a070b4b2ade8a078066af694c20fa6d5f2200eb1eb2bf742887
Contents?: true
Size: 492 Bytes
Versions: 61
Compression:
Stored size: 492 Bytes
Contents
#!/usr/bin/env ruby
# Waits for Kafka to be ready
# Useful in CI where Kafka needs to be fully started before we run any tests
require 'karafka'
Karafka::App.setup do |config|
config.kafka[:'bootstrap.servers'] = '127.0.0.1:9092'
end
60.times do
begin
# Stop if we can connect to the cluster and get info
exit if Karafka::Admin.cluster_info
rescue Rdkafka::RdkafkaError
puts "Kafka not available, retrying..."
sleep(1)
end
end
puts 'Kafka not available!'
exit 1
Version data entries
61 entries across 61 versions & 2 rubygems