lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.0.13 vs lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.0.14

@@ -3,10 +3,10 @@
 class KafkaInput < Input
   Plugin.register_input('kafka', self)
 
   config_param :format, :string, :default => 'json' # (json|text|ltsv)
   config_param :host, :string, :default => 'localhost'
-  config_param :port, :integer, :default => 2181
+  config_param :port, :integer, :default => 9092
   config_param :interval, :integer, :default => 1 # seconds
   config_param :topics, :string
   config_param :client_id, :string, :default => 'kafka'
   config_param :partition, :integer, :default => 0
   config_param :offset, :integer, :default => -1