KafkaCommonStep (ReadyAPI functional (soapui-pro) SDK 3.57.0)

com.eviware.soapui.impl.multiconfiguration.kafka.KafkaCommonStep

```
public abstract class KafkaCommonStep
extends ProMultiConfigurationTestStep
```
Base class for Kafka test step implementation It contains common code for Subscribe and Publish test steps

Nested Class Summary

Nested classes
Modifiers	Name	Description
`class`	`KafkaCommonStep.KafkaCommonConnectionSettingsImpl`

Field Summary

Fields
Modifiers	Name	Description
`static java.lang.String`	`SMART_BEAR_OAUTH2_ACCESS_TOKEN_TEMP_FILE`

Inherited fields
Fields inherited from class	Fields
`class ProMultiConfigurationTestStep`	`PRODUCER_PARAMETER_VALUE_PARAMETER, UPDATE_TEST_STEP_UI_CONTENT, UPDATE_TEST_STEP_UI_METADATA`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`public void`	`addEndpointChangeListener(EndpointChangeListener listener)`
	`public void`	`addOperationPropertyChangeListener(java.beans.PropertyChangeListener listener)`
	`public boolean`	`dependsOn(AbstractWsdlModelItem<?> modelItem)`
	`public abstract MultiConfigurationStepView`	`getActiveStepType()`
	`public java.lang.String`	`getChannelSetting()`
	`public JSONObject`	`getConnectionProperties()`
	`public abstract KafkaCommonConnectionSettingsImpl`	`getConnectionSettings()`
	`public MessageType`	`getDefaultKeyType()`
	`public MessageType`	`getDefaultMessageType()`
	`public java.lang.String`	`getEndpointSetting()`
	`public Interface<?>`	`getInterface()`
	`public java.util.Vector<java.lang.String>`	`getKeyMessageTypes()`
	`public java.lang.String`	`getKeySchemaContent()`
	`public Enum`	`getKeySchemaType()`
	`public abstract java.lang.String`	`getKeyType()`
	`public BaseMessageDrivenOperation<?>`	`getOperation()`
	`public java.util.List<java.lang.String>`	`getPossibleMessageTypes(boolean forRequest)`
	`public Descriptor`	`getProtobufKeyType()`
	`public Descriptor`	`getProtobufMessageType()`
	`public java.lang.String`	`getProtocolName()`
	`public java.util.Collection<Interface>`	`getRequiredInterfaces()`
	`public java.lang.String`	`getResourceContent()`
	`public MCResourceType`	`getResourceType()`
	`public java.lang.String`	`getSchemaContent()`
	`public Enum`	`getSchemaType()`
	`public JSONObject`	`getSchemas()`
	`public void`	`propertyChange(java.beans.PropertyChangeEvent propertyChangeEvent)`
	`public void`	`release()`
	`public void`	`reloadConnectionProperties()`
	`public void`	`removeEndpointChangeListener()`
	`public void`	`removeOperationPropertyChangeListener(java.beans.PropertyChangeListener listener)`
	`public boolean`	`requiresSchemaConfiguration(MessageType messageType)`
	`public void`	`setKeySchema(java.lang.String keySchema)`
	`public void`	`setOperationId(java.lang.String operationId)`
	`public void`	`setProtobufKeyType(java.lang.String schemaContent)`
	`public void`	`setProtobufMessageType(java.lang.String schemaContent)`
	`public void`	`setValueSchema(java.lang.String valueSchema)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class ProMultiConfigurationTestStep`	addAssertion, addAssertionsListener, addEndpointChangeListener, areBuiltInProfilesSupported, beforeSave, canAssert, clone, cloneAssertion, erase, getActiveStepType, getAssertableContent, getAssertableContentAsXml, getAssertableType, getAssertionAt, getAssertionByName, getAssertionCount, getAssertionList, getAssertionResultsSupport, getAssertionStatus, getAssertions, getAuthProfile, getAuthProfileHolder, getCancelActionDescription, getConfigAdapter, getConfigEndpoint, getDefaultAssertableContent, getDefaultMessageType, getEndpoint, getIcon, getInitialRequestMessage, getInterface, getMessageContent, getMessageType, getMetadataParameters, getOperation, getOperationName, getPossibleMessageTypes, getPropertyExpansions, getRequiredInterfaces, getResourceContent, getResourceType, getTestRequest, getTestStep, getViewAsListForMessageType, initNew, insertAssertion, isAuthProfileSupported, isTestStepExecuting, moveAssertion, prepare, propertyChange, release, removeAssertion, removeAssertionsListener, removeEndpointChangeListener, resetConfigOnMove, run, setAuthProfile, setConfigEndpoint, setEndpoint, setKeyType, setMessageContent, setMessageType, setOperationId, setTestStepRunListener, setTestStepTopPanelHandler, updateAssertionsStatus, updateCustomPropertiesView

- Field Detail
  - public static final java.lang.String SMART_BEAR_OAUTH2_ACCESS_TOKEN_TEMP_FILE
- Method Detail
  - @java.lang.Override public void addEndpointChangeListener(EndpointChangeListener listener)
  - public void addOperationPropertyChangeListener(java.beans.PropertyChangeListener listener)
  - @java.lang.Override public boolean dependsOn(AbstractWsdlModelItem<?> modelItem)
  - @java.lang.Override public abstract MultiConfigurationStepView getActiveStepType()
  - public java.lang.String getChannelSetting()
  - public JSONObject getConnectionProperties()
  - public abstract KafkaCommonConnectionSettingsImpl getConnectionSettings()
  - public MessageType getDefaultKeyType()
  - @java.lang.Override public MessageType getDefaultMessageType()
  - public java.lang.String getEndpointSetting()
  - @java.lang.Override @org.jetbrains.annotations.Nullable public Interface<?> getInterface()
  - public java.util.Vector<java.lang.String> getKeyMessageTypes()
  - @org.jetbrains.annotations.Nullable public java.lang.String getKeySchemaContent()
  - @org.jetbrains.annotations.Nullable public Enum getKeySchemaType()
  - public abstract java.lang.String getKeyType()
  - @java.lang.Override public BaseMessageDrivenOperation<?> getOperation()
  - @java.lang.Override public java.util.List<java.lang.String> getPossibleMessageTypes(boolean forRequest)
  - @org.jetbrains.annotations.Nullable public Descriptor getProtobufKeyType()
  - @org.jetbrains.annotations.Nullable public Descriptor getProtobufMessageType()
  - @java.lang.Override public java.lang.String getProtocolName()
  - @java.lang.Override public java.util.Collection<Interface> getRequiredInterfaces()
  - @java.lang.Override public java.lang.String getResourceContent()
  - @java.lang.Override public MCResourceType getResourceType()
  - @org.jetbrains.annotations.Nullable public java.lang.String getSchemaContent()
  - @org.jetbrains.annotations.Nullable public Enum getSchemaType()
  - public JSONObject getSchemas()
  - @java.lang.Override public void propertyChange(java.beans.PropertyChangeEvent propertyChangeEvent)
  - @java.lang.Override public void release()
  - public void reloadConnectionProperties()
  - @java.lang.Override public void removeEndpointChangeListener()
  - public void removeOperationPropertyChangeListener(java.beans.PropertyChangeListener listener)
  - public boolean requiresSchemaConfiguration(MessageType messageType)
  - public void setKeySchema(java.lang.String keySchema)
  - @java.lang.Override public void setOperationId(java.lang.String operationId)
  - public void setProtobufKeyType(java.lang.String schemaContent)
  - public void setProtobufMessageType(java.lang.String schemaContent)
  - public void setValueSchema(java.lang.String valueSchema)

Summary:
Nested
Field
Method

| Detail:
Field
Method

ReadyAPI functional (soapui-pro) SDK 3.57.0

[Java] Class KafkaCommonStep

Nested Class Summary

Field Summary

Methods Summary

Inherited Methods Summary

Field Detail

public static final java.lang.String SMART_BEAR_OAUTH2_ACCESS_TOKEN_TEMP_FILE

Method Detail

@java.lang.Override public void addEndpointChangeListener(EndpointChangeListener listener)

public void addOperationPropertyChangeListener(java.beans.PropertyChangeListener listener)

@java.lang.Override public boolean dependsOn(AbstractWsdlModelItem<?> modelItem)

@java.lang.Override public abstract MultiConfigurationStepView getActiveStepType()

public java.lang.String getChannelSetting()

public JSONObject getConnectionProperties()

public abstract KafkaCommonConnectionSettingsImpl getConnectionSettings()

public MessageType getDefaultKeyType()

@java.lang.Override public MessageType getDefaultMessageType()

public java.lang.String getEndpointSetting()

@java.lang.Override @org.jetbrains.annotations.Nullable public Interface<?> getInterface()

public java.util.Vector<java.lang.String> getKeyMessageTypes()

@org.jetbrains.annotations.Nullable public java.lang.String getKeySchemaContent()

@org.jetbrains.annotations.Nullable public Enum getKeySchemaType()

public abstract java.lang.String getKeyType()

@java.lang.Override public BaseMessageDrivenOperation<?> getOperation()

@java.lang.Override public java.util.List<java.lang.String> getPossibleMessageTypes(boolean forRequest)

@org.jetbrains.annotations.Nullable public Descriptor getProtobufKeyType()

@org.jetbrains.annotations.Nullable public Descriptor getProtobufMessageType()

@java.lang.Override public java.lang.String getProtocolName()

@java.lang.Override public java.util.Collection<Interface> getRequiredInterfaces()

@java.lang.Override public java.lang.String getResourceContent()

@java.lang.Override public MCResourceType getResourceType()

@org.jetbrains.annotations.Nullable public java.lang.String getSchemaContent()

@org.jetbrains.annotations.Nullable public Enum getSchemaType()

public JSONObject getSchemas()

@java.lang.Override public void propertyChange(java.beans.PropertyChangeEvent propertyChangeEvent)

@java.lang.Override public void release()

public void reloadConnectionProperties()

@java.lang.Override public void removeEndpointChangeListener()

public void removeOperationPropertyChangeListener(java.beans.PropertyChangeListener listener)

public boolean requiresSchemaConfiguration(MessageType messageType)

public void setKeySchema(java.lang.String keySchema)

@java.lang.Override public void setOperationId(java.lang.String operationId)

public void setProtobufKeyType(java.lang.String schemaContent)

public void setProtobufMessageType(java.lang.String schemaContent)

public void setValueSchema(java.lang.String valueSchema)