Join lines in message Payload
Change-Id: Ie1a6d11b8cc18269076e22d80a30dcf444e15596
diff --git a/heka/files/lua/decoders/zookeeper.lua b/heka/files/lua/decoders/zookeeper.lua
index ed3a338..07c3277 100644
--- a/heka/files/lua/decoders/zookeeper.lua
+++ b/heka/files/lua/decoders/zookeeper.lua
@@ -11,6 +11,9 @@
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- See the License for the specific language governing permissions and
-- limitations under the License.
+
+require 'string'
+
local l = require 'lpeg'
local utils = require 'lma_utils'
l.locale(l)
@@ -28,7 +31,7 @@
}
function process_message ()
- local log = read_message("Payload")
+ local msg = string.gsub(read_message('Payload'), "\n", "#")
local logger = read_message("Logger")
local m = java.ZookeeperLogGrammar:match(log)
if not m then