@Test
@Disabled("You may use this to test the local instance of Elastic.")
void testManualSend() {

    // Given
    final String recordId = UUID.randomUUID().toString();
    final ElasticIndexConfigDoc elasticIndexConfigDoc = new ElasticIndexConfigDoc();
    elasticIndexConfigDoc.setElasticHttpUrl("http://localhost:9200");
      elasticIndexConfigDoc.setTransportHosts("localhost:9300");
      elasticIndexConfigDoc.setClusterName("docker-cluster");
    final ElasticIndexWriter stroomElasticProducer = new HttpElasticIndexWriter(elasticIndexConfigDoc);
    final String STAT_NAME = "stat-name";
    final String STAT_TYPE = "stat-type";
    final String STAT_TIME = "stat-time";
    final Map<String, String> record = new HashMap<>();
    record.put(STAT_NAME, UUID.randomUUID().toString());
    record.put(STAT_TYPE, "test");
    record.put(STAT_TIME, new Date().toString());
    // When
    stroomElasticProducer.write(recordId, "statistics", "line", record, DEFAULT_CALLBACK);
    // Then: manually check your Elastic instances 'statistics' index for 'test'
}