ElasticsearchSinkOptions 链接如何设置账号密码

对于ElasticsearchSinkOptions的账号密码设置，您需要在连接字符串的末尾添加以下参数：

http.auth.username=yourusername

http.auth.password=yourpassword

示例代码如下：

ElasticsearchSinkOptions.Builder builder = new ElasticsearchSinkOptions.Builder<>();
builder.withConnectionConfig(new HttpHost("localhost", 9200))
        .withAuth("yourusername", "yourpassword")
        .withBulkFlushMaxSizeMb(1);

其中，yourusername和yourpassword分别代表您的Elasticsearch账户名和密码。请注意，将此信息存储在代码中是不安全的，最好将其存储在安全的配置文件或密钥管理器中。

相关问题

ElasticsearchSinkOptions 如何连接有密码的ES

集群？

对于连接有密码的Elasticsearch集群，可以使用以下配置：

Map<String, String> config = new HashMap<>();
config.put("cluster.name", "myClusterName");
config.put("client.transport.sniff", "true");
config.put("xpack.security.user", "myUsername:myPassword");

ElasticsearchSinkOptions<String> elasticsearchSinkOptions = ElasticsearchSinkOptions.builder()
    .withConnectionConfig(ConnectionConfig.create(config))
    .withIndex("my_index")
    .withType("my_type")
    .build();

其中 `cluster.name` 为Elasticsearch集群的名称，`client.transport.sniff` 为是否开启节点自动发现功能，`xpack.security.user` 为ES集群的用户名和密码，用冒号分隔。您需要将 `myClusterName`、`myUsername` 和 `myPassword` 替换成您实际使用的值。

ElasticsearchSinkOptions 如何连接ES

？要连接Elasticsearch，您需要设置ElasticsearchSinkOptions中的以下属性：

1.集群名称（ClusterName）-Elasticsearch集群的名称。默认情况下，它是“elasticsearch”。

2.节点URL（NodeUris）-要连接的Elasticsearch节点的URL。您可以为多个URL设置逗号分隔的字符串。

3.索引名称（IndexName）-要向其写入日志的Elasticsearch索引的名称。

4.索引日期格式（IndexDateFormat）-索引名称中日期的格式。它可以是Java日期格式字符串。

5.日志类型（LogType）-区分不同类型的日志消息的字段。

下面是一个示例，以Connect及其配置方式为例：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-consumer-group");

Sink sink = new ElasticsearchSink(props, new JsonSerializer<>(), new ElasticsearchSinkOptions.Builder()
                                                                         .withClusterName("elasticsearch")
                                                                         .withNodeUris("http://localhost:9200")
                                                                         .withIndexName("logstash-%{+YYYY.MM.dd}")
                                                                         .withLogType("kafka-connect")
                                                                         .build(
));

在这个示例中，我们使用ElasticsearchSinkOptions.Builder来设置与Elasticsearch连接相关的属性。我们将集群名称设置为“elasticsearch”，节点URL设置为“http://localhost:9200”，索引名称设置为“logstash-%{+YYYY.MM.dd}”，索引日期格式设置为“YYYY.MM.dd”，日志类型设置为“kafka-connect”。