@PublicEvolving public class SourceConfiguration extends Object implements Serializable
Constructor and Description |
---|
SourceConfiguration(Configuration configuration) |
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() |
public SourceConfiguration(Configuration configuration)
public boolean enablePartitionDiscovery()
public long getPartitionDiscoveryIntervalMs()
public boolean isEnableAutoAcknowledgeMessage()
public long getAutoCommitCursorInterval()
public long getTransactionTimeoutMillis()
public java.time.Duration getMaxFetchTime()
public int getMaxFetchRecords()
public CursorVerification getVerifyInitialOffsets()
public String getSubscriptionName()
public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType()
public org.apache.pulsar.client.api.SubscriptionMode getSubscriptionMode()
public String getSubscriptionDesc()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.