@Override
  public Client getClient() {
    Settings settings = Settings.settingsBuilder()
        .put(clientSettings)
        .build();

    TransportAddress address = new InetSocketTransportAddress(new InetSocketAddress(transportHost, transportPort));

    return TransportClient.builder().settings(settings).build().addTransportAddress(address);
  }
A {@link ClientFactory} that creates a {@link org.elasticsearch.node.Node} client that connects
and joins an Elasticsearch cluster.

<p>
This requires both the host and port properties to be set.
Other settings can be configured via Elasticsearch settings in the properties of the Samza job.
</p>
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/TransportClientFactory.java