improve kafka intake stability

We had garbage in our intake (as in valid json, but not valid message)

parser.parse() can throw exception which weren't caught. This causes realtime to stop intaking :(

This is a hotfix, thought you might want to merge this to master