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