@PublicEvolving public class KinesisConnectorOptions extends AsyncSinkConnectorOptions
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
AWS_REGION |
static ConfigOption<Boolean> |
SINK_FAIL_ON_ERROR |
static ConfigOption<String> |
SINK_PARTITIONER |
static ConfigOption<String> |
SINK_PARTITIONER_FIELD_DELIMITER |
static ConfigOption<String> |
STREAM |
FLUSH_BUFFER_SIZE, FLUSH_BUFFER_TIMEOUT, MAX_BATCH_SIZE, MAX_BUFFERED_REQUESTS, MAX_IN_FLIGHT_REQUESTS
Constructor and Description |
---|
KinesisConnectorOptions() |
public static final ConfigOption<String> STREAM
public static final ConfigOption<String> AWS_REGION
public static final ConfigOption<String> SINK_PARTITIONER
public static final ConfigOption<String> SINK_PARTITIONER_FIELD_DELIMITER
public static final ConfigOption<Boolean> SINK_FAIL_ON_ERROR
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.