Class PulsarClientConf

java.lang.Object
io.nosqlbench.adapter.pulsar.util.PulsarClientConf
public class PulsarClientConf extends Object

  • Constructor Details

    • PulsarClientConf

      public PulsarClientConf(String fileName)

  • Method Details

    • readRawConfFromFile

      public void readRawConfFromFile(String fileName)

    • getSchemaConfMapRaw

      public Map<String,String> getSchemaConfMapRaw()

    • getClientConfMapRaw

      public Map<String,String> getClientConfMapRaw()

    • getProducerConfMapRaw

      public Map<String,String> getProducerConfMapRaw()

    • getProducerConfMapTgt

      public Map<String,Object> getProducerConfMapTgt()

    • getConsumerConfMapRaw

      public Map<String,String> getConsumerConfMapRaw()

    • getConsumerConfMapTgt

      public Map<String,Object> getConsumerConfMapTgt()

    • getReaderConfMapRaw

      public Map<String,String> getReaderConfMapRaw()

    • getReaderConfMapTgt

      public Map<String,Object> getReaderConfMapTgt()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • hasSchemaConfKey

      public boolean hasSchemaConfKey(String key)
      ///////////////

    • getSchemaConfValueRaw

      public String getSchemaConfValueRaw(String key)

    • hasClientConfKey

      public boolean hasClientConfKey(String key)
      ///////////////

    • getClientConfValueRaw

      public String getClientConfValueRaw(String key)

    • hasProducerConfKey

      public boolean hasProducerConfKey(String key)
      ///////////////

    • getProducerConfValueRaw

      public String getProducerConfValueRaw(String key)

    • hasConsumerConfKey

      public boolean hasConsumerConfKey(String key)
      ///////////////

    • getConsumerConfValueRaw

      public String getConsumerConfValueRaw(String key)

    • getConsumerTimeoutSeconds

      public int getConsumerTimeoutSeconds()

    • hasReaderConfKey

      public boolean hasReaderConfKey(String key)
      ///////////////

    • getReaderConfValueRaw

      public String getReaderConfValueRaw(String key)