CheckElasticsearchDocuments fetches all documents from the passed index and checks for the expected number of matches.

ConsumeTestData consumes data from the passed topic, stopping when it reaches the expected number of records or times out.

ProduceTestData generates syslog entries onto the test topic.