use the context to retrieve the pipeline_id

Author: w32-blaster

lib/logstash/inputs/kafka.rb

@@ -135,7 +135,6 @@ class LogStash::Inputs::Kafka < LogStash::Inputs::Base
   def pipeline_id
     respond_to?(:execution_context) ? execution_context.pipeline_id : "main"
   end
-
   # The size of the TCP receive buffer (SO_RCVBUF) to use when reading data.
   config :receive_buffer_bytes, :validate => :string
   # The amount of time to wait before attempting to reconnect to a given host.

spec/unit/inputs/kafka_spec.rb

@@ -30,8 +30,7 @@ def wakeup
 end
 
 describe LogStash::Inputs::Kafka do
-  let(:pipeline_id) { SecureRandom.hex(8)}
-  let(:config) { { 'topics' => ['logstash'], 'consumer_threads' => 4, 'pipeline_id' => pipeline_id } }
+  let(:config) { { 'topics' => ['logstash'], 'consumer_threads' => 4 } }
   subject { LogStash::Inputs::Kafka.new(config) }
 
   it "should register" do