Field Detail

• public Enum DEFAULT_CLOSE_CONDITION_TYPE

• public int DEFAULT_MAX_IDLE_TIME

• public int DEFAULT_MAX_MESSAGES_RECEIVED

• public int DEFAULT_MAX_RUN_TIME

Method Detail

• public Enum getCloseConditionType()

• public int getMaxIdleTime()

• public int getMaxMessagesReceived()

• public int getMaxRunTime()

• public PropertiesTypeConfig getPublishConnectionProperties()

• public java.lang.String getSchemaRegistryAuthProfile()

• public java.lang.String getSchemaRegistryUrl()

• public KafkaConnectionSettingsHolder.SettingsType getSettingsType()

• public PropertiesTypeConfig getSubscribeConnectionProperties()

• public void setCloseConditionType(Enum closeConditionType)

• public void setMaxIdleTime(int maxIdleTime)

• public void setMaxMessagesReceived(int maxMessagesReceived)

• public void setMaxRunTime(int maxRunTime)

• public void setSchemaRegistryAuthProfile(java.lang.String schemaRegistryAuthProfile)

• public void setSchemaRegistryUrl(java.lang.String schemaRegistryUrl)

• public boolean showConfluentSettings()