org.apache.flink.connector.pulsar.source.config

Class SourceConfiguration

java.lang.Object

org.apache.flink.connector.pulsar.source.config.SourceConfiguration

All Implemented Interfaces:

Serializable

@PublicEvolving
public class SourceConfiguration
extends Object
implements Serializable

The configure class for pulsar source.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SourceConfiguration(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
boolean	enablePartitionDiscovery()
long	getAutoCommitCursorInterval()
int	getMaxFetchRecords()
java.time.Duration	getMaxFetchTime()
long	getPartitionDiscoveryIntervalMs()
String	getSubscriptionDesc() Convert the subscription into a readable str.
org.apache.pulsar.client.api.SubscriptionMode	getSubscriptionMode()
String	getSubscriptionName()
org.apache.pulsar.client.api.SubscriptionType	getSubscriptionType()
long	getTransactionTimeoutMillis()
CursorVerification	getVerifyInitialOffsets()
boolean	isEnableAutoAcknowledgeMessage()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SourceConfiguration

public SourceConfiguration(Configuration configuration)

Method Detail

enablePartitionDiscovery

public boolean enablePartitionDiscovery()

getPartitionDiscoveryIntervalMs

public long getPartitionDiscoveryIntervalMs()

isEnableAutoAcknowledgeMessage

public boolean isEnableAutoAcknowledgeMessage()

getAutoCommitCursorInterval

public long getAutoCommitCursorInterval()

getTransactionTimeoutMillis

public long getTransactionTimeoutMillis()

getMaxFetchTime

public java.time.Duration getMaxFetchTime()

getMaxFetchRecords

public int getMaxFetchRecords()

getVerifyInitialOffsets

public CursorVerification getVerifyInitialOffsets()

getSubscriptionName

public String getSubscriptionName()

getSubscriptionType

public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType()

getSubscriptionMode

public org.apache.pulsar.client.api.SubscriptionMode getSubscriptionMode()

getSubscriptionDesc

public String getSubscriptionDesc()

Convert the subscription into a readable str.