public interface KafkaSubscribeConnectionSettings extends KafkaCommonConnectionSettings
Interface for Kafka Subscribe connection settings
| Type Params | Return Type | Name and description |
|---|---|---|
|
public Enum |
getCloseConditionType() |
|
public boolean |
getIgnoreMessagesBeforeConnect() |
|
public int |
getMaxIdleTime() |
|
public int |
getMaxMessagesReceived() |
|
public int |
getMaxRunTime() |
|
public PropertiesTypeConfig |
getSubscribeConnectionProperties() |
|
public void |
setCloseConditionType(Enum closeConditionType) |
|
public void |
setIgnoreMessagesBeforeConnect(boolean ignoreMessagesBeforeConnect) |
|
public void |
setMaxIdleTime(int maxIdleTime) |
|
public void |
setMaxMessagesReceived(int maxMessagesReceived) |
|
public void |
setMaxRunTime(int maxRunTime) |
| Methods inherited from class | Name |
|---|---|
interface KafkaCommonConnectionSettings |
getSchemaRegistryAuthProfile, getSchemaRegistryUrl, getSettingsType, setSchemaRegistryAuthProfile, setSchemaRegistryUrl, showConfluentSettings |