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