@PublicEvolving public class SinkConfiguration extends PulsarConfiguration
confData
Constructor and Description |
---|
SinkConfiguration(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
DeliveryGuarantee |
getDeliveryGuarantee()
The delivery guarantee changes the behavior of
PulsarWriter . |
int |
getMaxRecommitTimes()
The maximum allowed recommitting time for a Pulsar transaction.
|
MessageKeyHash |
getMessageKeyHash()
The message key's hash logic for routing the message into one Pulsar partition.
|
int |
getPartitionSwitchSize()
Switch the partition to write when we have written the given size of messages.
|
long |
getTopicMetadataRefreshInterval()
Auto-update the topic metadata in a fixed interval (in ms).
|
long |
getTransactionTimeoutMillis()
Pulsar's transactions have a timeout mechanism for the uncommitted transaction.
|
int |
hashCode() |
boolean |
isEnableMetrics()
Whether to expose the metrics from Pulsar Producer.
|
boolean |
isEnableSchemaEvolution()
If we should serialize and send the message with a specified Pulsar
Schema instead
the default Schema.BYTES . |
get, getProperties, useOption, useOption
addAll, addAll, addAllToProperties, removeConfig
clone, contains, containsKey, fromMap, get, getBoolean, getBoolean, getBoolean, getBytes, getClass, getDouble, getDouble, getDouble, getEnum, getFloat, getFloat, getFloat, getInteger, getInteger, getInteger, getLong, getLong, getLong, getOptional, getString, getString, getString, getValue, keySet, read, removeKey, set, setBoolean, setBoolean, setBytes, setClass, setDouble, setDouble, setFloat, setFloat, setInteger, setInteger, setLong, setLong, setString, setString, toMap, toString, write
public SinkConfiguration(Configuration configuration)
public DeliveryGuarantee getDeliveryGuarantee()
PulsarWriter
.public long getTransactionTimeoutMillis()
Sink.InitContext
, we have to expose this option. Make
sure this value is greater than the checkpoint interval. Create a pulsar producer builder by
using the given Configuration.public long getTopicMetadataRefreshInterval()
public int getPartitionSwitchSize()
public MessageKeyHash getMessageKeyHash()
public boolean isEnableSchemaEvolution()
Schema
instead
the default Schema.BYTES
. This switch is only used for PulsarSchemaWrapper
.public int getMaxRecommitTimes()
public boolean isEnableMetrics()
public boolean equals(Object o)
equals
in class Configuration
public int hashCode()
hashCode
in class Configuration
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.