|
2 | 2 | require "rdkafka"
|
3 | 3 |
|
4 | 4 | if ["redhat", "amazon"].include?(os[:family])
|
5 |
| -describe "rdkafka" do |
6 |
| - it "can receive message via Rdkafka client" do |
7 |
| - config = { |
8 |
| - "bootstrap.servers": "localhost:9092", |
9 |
| - "group.id": "test" |
10 |
| - } |
11 |
| - consumer = Rdkafka::Config.new(config).consumer |
12 |
| - consumer.subscribe("test") |
| 5 | + describe "rdkafka" do |
| 6 | + it "can receive message via Rdkafka client" do |
| 7 | + config = { |
| 8 | + "bootstrap.servers": "localhost:9092", |
| 9 | + "group.id": "test" |
| 10 | + } |
| 11 | + consumer = Rdkafka::Config.new(config).consumer |
| 12 | + consumer.subscribe("test") |
13 | 13 |
|
14 |
| - wait_for_consumer_assignment(consumer) |
| 14 | + wait_for_consumer_assignment(consumer) |
15 | 15 |
|
16 |
| - `echo "Hello, rdkafka" | /usr/bin/kafka-console-producer --broker-list localhost:9092 --topic test` |
| 16 | + `echo "Hello, rdkafka" | /usr/bin/kafka-console-producer --broker-list localhost:9092 --topic test` |
17 | 17 |
|
18 |
| - message = consumer.each { |message| break message } |
19 |
| - expect(message.payload).to eq "Hello, rdkafka" |
| 18 | + message = consumer.each { |message| break message } |
| 19 | + expect(message.payload).to eq "Hello, rdkafka" |
| 20 | + end |
20 | 21 | end
|
21 |
| -end |
22 | 22 |
|
23 |
| -describe "fluent-plugin-kafka" do |
24 |
| - it "can receive message via fluent-plugin-kafka" do |
25 |
| - `echo "Hello, fluent-plugin-kafka" | /usr/bin/kafka-console-producer --broker-list localhost:9092 --topic test` |
26 |
| - Dir.glob("/tmp/log/td-agent/*.log") do |path| |
27 |
| - File.open(path) do |file| |
28 |
| - expect(JSON.parse(file.readlines.last)["message"]).to eq "Hello, fluent-plugin-kafka" |
| 23 | + describe "fluent-plugin-kafka" do |
| 24 | + it "can receive message via fluent-plugin-kafka" do |
| 25 | + `echo "Hello, fluent-plugin-kafka" | /usr/bin/kafka-console-producer --broker-list localhost:9092 --topic test` |
| 26 | + Dir.glob("/tmp/log/td-agent/*.log") do |path| |
| 27 | + File.open(path) do |file| |
| 28 | + expect(JSON.parse(file.readlines.last)["message"]).to eq "Hello, fluent-plugin-kafka" |
| 29 | + end |
29 | 30 | end
|
30 | 31 | end
|
31 | 32 | end
|
32 | 33 | end
|
33 |
| -end |
0 commit comments