Package com.tibco.tibjms.admin
Class KafkaTransportInfo
- java.lang.Object
-
- com.tibco.tibjms.admin.TransportInfo
-
- com.tibco.tibjms.admin.KafkaTransportInfo
-
public class KafkaTransportInfo extends TransportInfo
This class represents Apache Kafka transports that are configured on the EMS server. Kafka transports are mechanisms for importing and exporting messages between EMS and Kafka.- Since:
- EMS 10.5.0
-
-
Field Summary
-
Fields inherited from class com.tibco.tibjms.admin.TransportInfo
NON_PERSISTENT, PERSISTENT, RELIABLE, TPORT_ALL, TPORT_FTL, TPORT_KAFKA, TPORT_PULSAR, TPORT_RV, TPORT_RVCM, TPORT_SS
-
-
Constructor Summary
Constructors Constructor Description KafkaTransportInfo(java.lang.Object json)For Internal use only, may be removed or deprecated in future.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.StringgetBrokers()Get the URL of the Kafka brokers the transport exchanges messages with.java.lang.StringgetSchemaRepository()Get the URL of the schema repository the transport uses for Avro deserialization.java.lang.StringtoString()-
Methods inherited from class com.tibco.tibjms.admin.TransportInfo
getExportHeaders, getExportProperties, getName, getQueueImportDeliveryMode, getTopicImportDeliveryMode, getType
-
-
-
-
Constructor Detail
-
KafkaTransportInfo
public KafkaTransportInfo(java.lang.Object json) throws JMSExceptionFor Internal use only, may be removed or deprecated in future.- Throws:
JMSException
-
-
Method Detail
-
getBrokers
public java.lang.String getBrokers()
Get the URL of the Kafka brokers the transport exchanges messages with.- Returns:
- the URL of the Kafka brokers
- Since:
- EMS 10.5.0
-
getSchemaRepository
public java.lang.String getSchemaRepository()
Get the URL of the schema repository the transport uses for Avro deserialization.- Returns:
- the URL of the schema repository
- Since:
- EMS 10.5.0
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-