From 7b99387960314dd9115f770775fc8814b460fd1b Mon Sep 17 00:00:00 2001 From: Tamas Szasz Date: Thu, 21 Feb 2019 20:04:27 +0200 Subject: [PATCH] modify integration spec --- spec/integration/inputs/kafka_spec.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spec/integration/inputs/kafka_spec.rb b/spec/integration/inputs/kafka_spec.rb index 4f178e6..4593152 100644 --- a/spec/integration/inputs/kafka_spec.rb +++ b/spec/integration/inputs/kafka_spec.rb @@ -13,7 +13,7 @@ let(:group_id_4) {rand(36**8).to_s(36)} let(:group_id_5) {rand(36**8).to_s(36)} let(:plain_config) { { 'topics' => ['logstash_topic_plain'], 'codec' => 'plain', 'group_id' => group_id_1, 'auto_offset_reset' => 'earliest'} } - let(:multi_consumer_config) { plain_config.merge({"group_id" => group_id_4, "client_id" => "spec", "consumer_threads" => 3, "pipeline_id" => "spec_pipeline"}) } + let(:multi_consumer_config) { plain_config.merge({"group_id" => group_id_4, "client_id" => "spec", "consumer_threads" => 3}) } let(:snappy_config) { { 'topics' => ['logstash_topic_snappy'], 'codec' => 'plain', 'group_id' => group_id_1, 'auto_offset_reset' => 'earliest'} } let(:lz4_config) { { 'topics' => ['logstash_topic_lz4'], 'codec' => 'plain', 'group_id' => group_id_1, 'auto_offset_reset' => 'earliest'} } let(:pattern_config) { { 'topics_pattern' => 'logstash_topic_.*', 'group_id' => group_id_2, 'codec' => 'plain', 'auto_offset_reset' => 'earliest'} } @@ -82,7 +82,7 @@ def thread_it(kafka_input, queue) wait(timeout_seconds).for {queue.length}.to eq(num_events) expect(queue.length).to eq(num_events) kafka_input.kafka_consumers.each_with_index do |consumer, i| - expect(consumer.metrics.keys.first.tags["client-id"]).to eq("spec-#{i}-spec_pipeline") + expect(consumer.metrics.keys.first.tags["client-id"]).to eq("spec-#{i}-main") end ensure t.kill