x
/
fuel-plugin-openstack-telemetry
Code Issues Proposed changes

Change decoder_module to decoder in kafka_input 

This change fixes issue with kafka-input initialization.

Change-Id: I38bc6ebfaa7e7c5fc37a512e31cce52f2213ba73
This commit is contained in:
Ilya Tyaptin 2016-09-21 16:59:20 +03:00
parent 038379060c
commit 4d385af992
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deployment_scripts/puppet/modules/telemetry/files/hindsight/run/input/kafka_input.lua
View File

@ -10,7 +10,7 @@ local brokerlist = read_config("brokerlist") or error("brokerlist must be se
local topics = read_config("topics") or error("topics must be set")
local consumer_conf = read_config("consumer_conf")
local topic_conf = read_config("topic_conf")
local decoder_module = read_config("decoder_module")
local decoder_module = read_config("decoder")
local send_error_messages = read_config("send_error_messages") or false
local inject = inject_message