ruby - Error response from daemon: 400 Bad Request: malformed Host header -
i trying consume messages kafka queue. returns:
400 bad request error: malformed host header.
it seems none of docker comments not running ruby. tested executing docker ps
command ruby. experiencing same error.
could please me execute docker commands ruby? i'm executing cucumber.
given(/^test kafka consumer$/) expect(testkafkaconsumer.consume("test_queue")).to include "testmessage" end module testkafkaconsumer class << self def consume(topic) cid = dockercompose.container_id "kafka" puts "hello world!!!" res = `docker ps` # uncomment kafka consumer #res = `docker exec #{cid} /opt/kafka/bin/kafka-simple-consumer-shell.sh --broker-list localhost:9092 --topic #{topic} --partition 0 --no-wait-at-logend 2>&1` raise "unable consume topic #{topic}. output was:\n#{res}" unless $?.success? end end end
Comments
Post a Comment