Either using beats library to consume hpfeeds directly, or text of TCP with JSON objects one per line