Class 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
    • Constructor Detail

      • KafkaTransportInfo

        public KafkaTransportInfo​(java.lang.Object json)
                           throws JMSException
        For 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:
        toString in class java.lang.Object