@PublicEvolving public final class PulsarSinkOptions extends Object
PulsarSinkBuilder.setConfig(ConfigOption, Object)
. The PulsarOptions
is also required
for pulsar source.for shared configure options.
public static final String SINK_CONFIG_PREFIX
public static final String PRODUCER_CONFIG_PREFIX
public static final ConfigOption<DeliveryGuarantee> PULSAR_WRITE_DELIVERY_GUARANTEE
public static final ConfigOption<Long> PULSAR_WRITE_TRANSACTION_TIMEOUT
public static final ConfigOption<Long> PULSAR_TOPIC_METADATA_REFRESH_INTERVAL
public static final ConfigOption<MessageKeyHash> PULSAR_MESSAGE_KEY_HASH
public static final ConfigOption<Boolean> PULSAR_WRITE_SCHEMA_EVOLUTION
public static final ConfigOption<Integer> PULSAR_MAX_RECOMMIT_TIMES
@Deprecated public static final ConfigOption<Integer> PULSAR_MAX_PENDING_MESSAGES_ON_PARALLELISM
public static final ConfigOption<Boolean> PULSAR_ENABLE_SINK_METRICS
public static final ConfigOption<String> PULSAR_PRODUCER_NAME
public static final ConfigOption<Long> PULSAR_SEND_TIMEOUT_MS
@Deprecated public static final ConfigOption<Integer> PULSAR_MAX_PENDING_MESSAGES
PulsarOptions.PULSAR_MEMORY_LIMIT_BYTES
since Pulsar 2.10.0@Deprecated public static final ConfigOption<Integer> PULSAR_MAX_PENDING_MESSAGES_ACROSS_PARTITIONS
PulsarOptions.PULSAR_MEMORY_LIMIT_BYTES
since Pulsar 2.10.0public static final ConfigOption<Long> PULSAR_BATCHING_MAX_PUBLISH_DELAY_MICROS
public static final ConfigOption<Integer> PULSAR_BATCHING_PARTITION_SWITCH_FREQUENCY_BY_PUBLISH_DELAY
public static final ConfigOption<Integer> PULSAR_BATCHING_MAX_MESSAGES
public static final ConfigOption<Integer> PULSAR_BATCHING_MAX_BYTES
public static final ConfigOption<Boolean> PULSAR_BATCHING_ENABLED
public static final ConfigOption<Boolean> PULSAR_CHUNKING_ENABLED
public static final ConfigOption<org.apache.pulsar.client.api.CompressionType> PULSAR_COMPRESSION_TYPE
public static final ConfigOption<Long> PULSAR_INITIAL_SEQUENCE_ID
public static final ConfigOption<Map<String,String>> PULSAR_PRODUCER_PROPERTIES
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.