Modifiers | Name | Description |
---|---|---|
static java.lang.String |
AVRO_SERIALIZER_NAME |
|
static java.lang.String |
BASIC_AUTH_CREDENTIALS_SOURCE_KEY_NAME |
|
static java.lang.String |
CONFLUENT_AVRO_SERIALIZER_NAME |
|
static java.lang.String |
CONFLUENT_PROTOBUF_SERIALIZER_NAME |
|
static java.lang.String |
KEY_SERIALIZER_DEFAULT_PROPERTY_VALUE |
|
static java.lang.String |
KEY_SERIALIZER_PROPERTY_NAME |
|
static java.lang.String |
MAX_BLOCK_MS_DEFAULT_VALUE_MS |
|
static java.lang.String |
MAX_BLOCK_MS_KEY |
|
static java.lang.String |
PROTOBUF_SERIALIZER_NAME |
|
static java.lang.String |
SCHEMA_PROPERTY_NAME |
|
static java.lang.String |
SCHEMA_REGISTRY_BASIC_AUTH_KEY_NAME |
|
static java.lang.String |
SCHEMA_REGISTRY_URL_KEY_NAME |
|
static java.lang.String |
VALUE_SERIALIZER_PROPERTY_DEFAULT_VALUE |
|
static java.lang.String |
VALUE_SERIALIZER_PROPERTY_NAME |
Type Params | Return Type | Name and description |
---|---|---|
|
static KafkaOperationType |
getActiveStepType(MultiConfigurationStepConfig multiConfigurationStepConfig) |
|
static KafkaConnectionSettingsConfig |
getConnectionSettingsConfigFromActiveEnvironment(MultiConfigurationTestStep multiConfigurationTestStep, WsdlProject project) |
|
static KafkaConnectionSettingsConfig |
getKafkaConnectionSettingsConfigFromEnvironmentSpec(ProMultiConfigurationTestStep multiConfigurationTestStep, java.lang.String environmentId, boolean createIfNotExist) |
Methods inherited from class | Name |
---|---|
class java.lang.Object |
java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |