{"action":"created","issue":{"url":"https://api.github.com/repos/Graylog2/graylog2-server/issues/1059","labels_url":"https://api.github.com/repos/Graylog2/graylog2-server/issues/1059/labels{/name}","comments_url":"https://api.github.com/repos/Graylog2/graylog2-server/issues/1059/comments","events_url":"https://api.github.com/repos/Graylog2/graylog2-server/issues/1059/events","html_url":"https://github.com/Graylog2/graylog2-server/issues/1059","id":61025992,"number":1059,"title":"Message decoding errors should log message source","user":{"login":"joschi","id":43951,"avatar_url":"https://avatars.githubusercontent.com/u/43951?v=3","gravatar_id":"","url":"https://api.github.com/users/joschi","html_url":"https://github.com/joschi","followers_url":"https://api.github.com/users/joschi/followers","following_url":"https://api.github.com/users/joschi/following{/other_user}","gists_url":"https://api.github.com/users/joschi/gists{/gist_id}","starred_url":"https://api.github.com/users/joschi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/joschi/subscriptions","organizations_url":"https://api.github.com/users/joschi/orgs","repos_url":"https://api.github.com/users/joschi/repos","events_url":"https://api.github.com/users/joschi/events{/privacy}","received_events_url":"https://api.github.com/users/joschi/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/Graylog2/graylog2-server/labels/infrastructure","name":"infrastructure","color":"c7def8"},{"url":"https://api.github.com/repos/Graylog2/graylog2-server/labels/inputs","name":"inputs","color":"009800"}],"state":"open","locked":false,"assignee":{"login":"kroepke","id":52014,"avatar_url":"https://avatars.githubusercontent.com/u/52014?v=3","gravatar_id":"","url":"https://api.github.com/users/kroepke","html_url":"https://github.com/kroepke","followers_url":"https://api.github.com/users/kroepke/followers","following_url":"https://api.github.com/users/kroepke/following{/other_user}","gists_url":"https://api.github.com/users/kroepke/gists{/gist_id}","starred_url":"https://api.github.com/users/kroepke/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kroepke/subscriptions","organizations_url":"https://api.github.com/users/kroepke/orgs","repos_url":"https://api.github.com/users/kroepke/repos","events_url":"https://api.github.com/users/kroepke/events{/privacy}","received_events_url":"https://api.github.com/users/kroepke/received_events","type":"User","site_admin":false},"milestone":{"url":"https://api.github.com/repos/Graylog2/graylog2-server/milestones/35","html_url":"https://github.com/Graylog2/graylog2-server/milestones/1.2.0","labels_url":"https://api.github.com/repos/Graylog2/graylog2-server/milestones/35/labels","id":1119344,"number":35,"title":"1.2.0","description":"","creator":{"login":"lennartkoopmann","id":35022,"avatar_url":"https://avatars.githubusercontent.com/u/35022?v=3","gravatar_id":"","url":"https://api.github.com/users/lennartkoopmann","html_url":"https://github.com/lennartkoopmann","followers_url":"https://api.github.com/users/lennartkoopmann/followers","following_url":"https://api.github.com/users/lennartkoopmann/following{/other_user}","gists_url":"https://api.github.com/users/lennartkoopmann/gists{/gist_id}","starred_url":"https://api.github.com/users/lennartkoopmann/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lennartkoopmann/subscriptions","organizations_url":"https://api.github.com/users/lennartkoopmann/orgs","repos_url":"https://api.github.com/users/lennartkoopmann/repos","events_url":"https://api.github.com/users/lennartkoopmann/events{/privacy}","received_events_url":"https://api.github.com/users/lennartkoopmann/received_events","type":"User","site_admin":false},"open_issues":23,"closed_issues":66,"state":"open","created_at":"2015-05-19T21:34:25Z","updated_at":"2015-08-25T12:35:05Z","due_on":null,"closed_at":null},"comments":4,"created_at":"2015-03-13T09:56:10Z","updated_at":"2015-08-25T13:13:20Z","closed_at":null,"body":"If a message written to the disk journal can't be decoded (e. g. because it's an invalid message format) the log message doesn't contain the source of the message, which might be useful to detect a broken producer:\r\n```\r\n2015-03-13 09:57:56,959  ERROR: org.graylog2.inputs.codecs.GelfCodec - Could not parse JSON! com.fasterxml.jackson.databind.JsonMappingException: No content to map due to end-of-input\r\n2015-03-13 09:57:56,959 WARN : org.graylog2.shared.buffers.ProcessBuffer - Unable to process event MessageEvent{raw=null, message=null}, sequence 39708\r\n```\r\nAdditionally, the disk journal utilities (e. g. `JournalDecode`) don't print the source address in error cases either."},"comment":{"url":"https://api.github.com/repos/Graylog2/graylog2-server/issues/comments/134580372","html_url":"https://github.com/Graylog2/graylog2-server/issues/1059#issuecomment-134580372","issue_url":"https://api.github.com/repos/Graylog2/graylog2-server/issues/1059","id":134580372,"user":{"login":"kroepke","id":52014,"avatar_url":"https://avatars.githubusercontent.com/u/52014?v=3","gravatar_id":"","url":"https://api.github.com/users/kroepke","html_url":"https://github.com/kroepke","followers_url":"https://api.github.com/users/kroepke/followers","following_url":"https://api.github.com/users/kroepke/following{/other_user}","gists_url":"https://api.github.com/users/kroepke/gists{/gist_id}","starred_url":"https://api.github.com/users/kroepke/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kroepke/subscriptions","organizations_url":"https://api.github.com/users/kroepke/orgs","repos_url":"https://api.github.com/users/kroepke/repos","events_url":"https://api.github.com/users/kroepke/events{/privacy}","received_events_url":"https://api.github.com/users/kroepke/received_events","type":"User","site_admin":false},"created_at":"2015-08-25T13:13:19Z","updated_at":"2015-08-25T13:13:19Z","body":"```\r\n2015-08-25 15:12:18,508 ERROR: org.graylog2.shared.buffers.processors.DecodingProcessor - Unable to decode raw message e9a0b040-4b2a-11e5-9fd5-fe3742453b88 (journal offset 342459) encoded as gelf received from /127.0.0.1:51205.\r\n2015-08-25 15:12:18,510 ERROR: org.graylog2.shared.buffers.processors.DecodingProcessor - Error processing message RawMessage{id=e9a0b040-4b2a-11e5-9fd5-fe3742453b88, journalOffset=342459, codec=gelf, payloadSize=181, timestamp=2015-08-25T15:12:18.500+02:00, remoteAddress=/127.0.0.1:51205}\r\ncom.fasterxml.jackson.core.JsonParseException: Unexpected end-of-input: expected close marker for OBJECT (from [Source: {\"version\": \"1.1\",\"host\":\"example.org\",\"short_message\":\"Short message\",\"full_message\":\"Backtrace here\r\n\r\nmore stuff\",\"level\":1,\"_user_id\":9001,\"_some_info\":\"foo\",\"_some_env_var\":\"bar\"; line: 1, column: 0])\r\n at [Source: {\"version\": \"1.1\",\"host\":\"example.org\",\"short_message\":\"Short message\",\"full_message\":\"Backtrace here\r\n\r\nmore stuff\",\"level\":1,\"_user_id\":9001,\"_some_info\":\"foo\",\"_some_env_var\":\"bar\"; line: 1, column: 363]\r\n\tat com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1576)\r\n\tat com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:533)\r\n\tat com.fasterxml.jackson.core.base.ParserMinimalBase._reportInvalidEOF(ParserMinimalBase.java:470)\r\n\tat com.fasterxml.jackson.core.base.ParserBase._handleEOF(ParserBase.java:501)\r\n\tat com.fasterxml.jackson.core.base.ParserBase._eofAsNextChar(ParserBase.java:509)\r\n\tat com.fasterxml.jackson.core.json.ReaderBasedJsonParser._skipWSOrEnd(ReaderBasedJsonParser.java:2018)\r\n\tat com.fasterxml.jackson.core.json.ReaderBasedJsonParser.nextFieldName(ReaderBasedJsonParser.java:743)\r\n\tat com.fasterxml.jackson.databind.deser.std.BaseNodeDeserializer.deserializeObject(JsonNodeDeserializer.java:219)\r\n\tat com.fasterxml.jackson.databind.deser.std.JsonNodeDeserializer.deserialize(JsonNodeDeserializer.java:69)\r\n\tat com.fasterxml.jackson.databind.deser.std.JsonNodeDeserializer.deserialize(JsonNodeDeserializer.java:15)\r\n\tat com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3702)\r\n\tat com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2262)\r\n\tat org.graylog2.inputs.codecs.GelfCodec.decode(GelfCodec.java:114)\r\n\tat org.graylog2.shared.buffers.processors.DecodingProcessor.processMessage(DecodingProcessor.java:136)\r\n\tat org.graylog2.shared.buffers.processors.DecodingProcessor.onEvent(DecodingProcessor.java:82)\r\n\tat org.graylog2.shared.buffers.processors.ProcessBufferProcessor.onEvent(ProcessBufferProcessor.java:58)\r\n\tat org.graylog2.shared.buffers.processors.ProcessBufferProcessor.onEvent(ProcessBufferProcessor.java:35)\r\n\tat com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:138)\r\n\tat com.codahale.metrics.InstrumentedExecutorService$InstrumentedRunnable.run(InstrumentedExecutorService.java:176)\r\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\r\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\r\n\tat java.lang.Thread.run(Thread.java:745)\r\n\r\n```"}}