<source> type mysql_replicator host localhost username dbuser password dbpass database testdb query SELECT login,userId,loginTime,sessionId,DATE_FORMAT(loginTime, '%Y-%m-%dT%k:%i:%s+09:00') as "@timestamp" FROM history WHERE DATE_ADD(loginTime, INTERVAL 1 MINUTE) > NOW(); primary_key sessionId interval 1m enable_delete no tag replicator.testdb.history.${event} </source> README には、"@timestamp":"201