@Test public void testDirectIsDefault() { assertEquals( DIRECT, new KafkaProducerOutputMeta().getConnectionType() ); }
public ConnectionType getConnectionType() { return connectionType; }
KafkaProducerOutputMeta extends BaseStepMeta implements StepMetaInterface { public ConnectionType getConnectionType() { return connectionType; } }
KafkaProducerOutputMeta extends BaseStepMeta implements StepMetaInterface { public ConnectionType getConnectionType() { return connectionType; } KafkaProducerOutputMeta(); }
KafkaProducerOutputMeta extends BaseStepMeta implements StepMetaInterface { public ConnectionType getConnectionType() { return connectionType; } KafkaProducerOutputMeta(); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override void setDefault(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId stepId, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId transformationId, ObjectId stepId ); @Override void getFields( RowMetaInterface rowMeta, String origin, RowMetaInterface[] info, StepMeta nextStep,
                         VariableSpace space, Repository repository, IMetaStore metaStore ); @Override StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta,
                                Trans trans ); @Override StepDataInterface getStepData(); @SuppressWarnings( "deprecation" ) String getDialogClassName(); @Metaverse.Node ( name = KAFKA_SERVER_METAVERSE, type = KAFKA_SERVER_METAVERSE ) @Metaverse.Property ( name = KAFKA_SERVER_METAVERSE, parentNodeName = KAFKA_SERVER_METAVERSE ) String getBootstrapServers(); String getClientId(); void setClientId( String clientId ); @Metaverse.Node ( name = KAFKA_TOPIC_METAVERSE, type = KAFKA_TOPIC_METAVERSE, link = LINK_WRITESTO, linkDirection = "IN" ) @Metaverse.Property ( name = TOPIC, parentNodeName = KAFKA_TOPIC_METAVERSE ) String getTopic(); void setTopic( String topic ); @Metaverse.Node ( name = KEY, type = RESOURCE, link = LINK_OUTPUTS, nameFromValue = FALSE, linkDirection = "IN" ) @Metaverse.NodeLink ( nodeName = KEY, parentNodeName = KAFKA_TOPIC_METAVERSE, linkDirection = "OUT" ) // @Metaverse.Property( name = KEY_FIELD_NAME, parentNodeName = KAFKA_TOPIC_METAVERSE) String getKeyField(); void setKeyField( String keyField ); @Metaverse.Node ( name = MESSAGE, type = RESOURCE, link = LINK_OUTPUTS, nameFromValue = FALSE, linkDirection = "IN" ) @Metaverse.NodeLink ( nodeName = MESSAGE, parentNodeName = KAFKA_TOPIC_METAVERSE, linkDirection = "OUT" ) // @Metaverse.Property( name = MSG_FIELD_NAME, parentNodeName = KAFKA_TOPIC_METAVERSE ) String getMessageField(); void setMessageField( String messageField ); ConnectionType getConnectionType(); void setConnectionType( final ConnectionType connectionType ); @Override String getXML(); NamedClusterService getNamedClusterService(); MetastoreLocator getMetastoreLocator(); String getClusterName(); void setClusterName( String clusterName ); void setDirectBootstrapServers( final String directBootstrapServers ); String getDirectBootstrapServers(); void setConfig( Map<String, String> config ); Map<String, String> getConfig(); void setNamedClusterService( NamedClusterService namedClusterService ); void setMetastoreLocator( MetastoreLocator metastoreLocator ); NamedClusterServiceLocator getNamedClusterServiceLocator(); void setNamedClusterServiceLocator(
    NamedClusterServiceLocator namedClusterServiceLocator ); Optional<JaasConfigService> getJaasConfigService(); }
KafkaProducerOutputMeta extends BaseStepMeta implements StepMetaInterface { public ConnectionType getConnectionType() { return connectionType; } KafkaProducerOutputMeta(); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override void setDefault(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId stepId, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId transformationId, ObjectId stepId ); @Override void getFields( RowMetaInterface rowMeta, String origin, RowMetaInterface[] info, StepMeta nextStep,
                         VariableSpace space, Repository repository, IMetaStore metaStore ); @Override StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta,
                                Trans trans ); @Override StepDataInterface getStepData(); @SuppressWarnings( "deprecation" ) String getDialogClassName(); @Metaverse.Node ( name = KAFKA_SERVER_METAVERSE, type = KAFKA_SERVER_METAVERSE ) @Metaverse.Property ( name = KAFKA_SERVER_METAVERSE, parentNodeName = KAFKA_SERVER_METAVERSE ) String getBootstrapServers(); String getClientId(); void setClientId( String clientId ); @Metaverse.Node ( name = KAFKA_TOPIC_METAVERSE, type = KAFKA_TOPIC_METAVERSE, link = LINK_WRITESTO, linkDirection = "IN" ) @Metaverse.Property ( name = TOPIC, parentNodeName = KAFKA_TOPIC_METAVERSE ) String getTopic(); void setTopic( String topic ); @Metaverse.Node ( name = KEY, type = RESOURCE, link = LINK_OUTPUTS, nameFromValue = FALSE, linkDirection = "IN" ) @Metaverse.NodeLink ( nodeName = KEY, parentNodeName = KAFKA_TOPIC_METAVERSE, linkDirection = "OUT" ) // @Metaverse.Property( name = KEY_FIELD_NAME, parentNodeName = KAFKA_TOPIC_METAVERSE) String getKeyField(); void setKeyField( String keyField ); @Metaverse.Node ( name = MESSAGE, type = RESOURCE, link = LINK_OUTPUTS, nameFromValue = FALSE, linkDirection = "IN" ) @Metaverse.NodeLink ( nodeName = MESSAGE, parentNodeName = KAFKA_TOPIC_METAVERSE, linkDirection = "OUT" ) // @Metaverse.Property( name = MSG_FIELD_NAME, parentNodeName = KAFKA_TOPIC_METAVERSE ) String getMessageField(); void setMessageField( String messageField ); ConnectionType getConnectionType(); void setConnectionType( final ConnectionType connectionType ); @Override String getXML(); NamedClusterService getNamedClusterService(); MetastoreLocator getMetastoreLocator(); String getClusterName(); void setClusterName( String clusterName ); void setDirectBootstrapServers( final String directBootstrapServers ); String getDirectBootstrapServers(); void setConfig( Map<String, String> config ); Map<String, String> getConfig(); void setNamedClusterService( NamedClusterService namedClusterService ); void setMetastoreLocator( MetastoreLocator metastoreLocator ); NamedClusterServiceLocator getNamedClusterServiceLocator(); void setNamedClusterServiceLocator(
    NamedClusterServiceLocator namedClusterServiceLocator ); Optional<JaasConfigService> getJaasConfigService(); static final String CLUSTER_NAME; static final String CONNECTION_TYPE; static final String DIRECT_BOOTSTRAP_SERVERS; static final String CLIENT_ID; static final String TOPIC; static final String KEY_FIELD; static final String MESSAGE_FIELD; static final String ADVANCED_CONFIG; static final String CONFIG_OPTION; static final String OPTION_PROPERTY; static final String OPTION_VALUE; }