Interface for Kafka Subscribe connection settings
Modifiers | Name | Description |
---|---|---|
Enum |
DEFAULT_CLOSE_CONDITION_TYPE |
|
int |
DEFAULT_MAX_IDLE_TIME |
|
int |
DEFAULT_MAX_MESSAGES_RECEIVED |
|
int |
DEFAULT_MAX_RUN_TIME |
Type Params | Return Type | Name and description |
---|---|---|
|
Enum |
getCloseConditionType() |
|
int |
getMaxIdleTime() |
|
int |
getMaxMessagesReceived() |
|
int |
getMaxRunTime() |
|
PropertiesTypeConfig |
getSubscribeConnectionProperties() |
|
void |
setCloseConditionType(Enum closeConditionType) |
|
void |
setMaxIdleTime(int maxIdleTime) |
|
void |
setMaxMessagesReceived(int maxMessagesReceived) |
|
void |
setMaxRunTime(int maxRunTime) |
Methods inherited from class | Name |
---|---|
interface KafkaCommonConnectionSettings |
getSchemaRegistryAuthProfile, getSchemaRegistryUrl, getSettingsType, setSchemaRegistryAuthProfile, setSchemaRegistryUrl, showConfluentSettings |