程序包 io.github.wooenrico.kafka.sender

类 SenderProperties

java.lang.Object
io.github.wooenrico.kafka.sender.SenderProperties
public class SenderProperties extends Object

  • 构造器详细资料

    • SenderProperties

      public SenderProperties()

  • 方法详细资料

    • getEnabled

      public Boolean getEnabled()

    • setEnabled

      public void setEnabled(Boolean enabled)

    • getProperties

      public Properties getProperties()

    • setProperties

      public void setProperties(Properties properties)

    • getCloseTimeout

      public Duration getCloseTimeout()

    • setCloseTimeout

      public void setCloseTimeout(Duration closeTimeout)

    • getQueueSize

      public int getQueueSize()

    • setQueueSize

      public void setQueueSize(int queueSize)

    • getSinksEmitTimeout

      public Duration getSinksEmitTimeout()

    • setSinksEmitTimeout

      public void setSinksEmitTimeout(Duration sinksEmitTimeout)

    • getSinksCacheSize

      public long getSinksCacheSize()

    • setSinksCacheSize

      public void setSinksCacheSize(long sinksCacheSize)

    • getSinksSubscribeAwait

      public Duration getSinksSubscribeAwait()

    • setSinksSubscribeAwait

      public void setSinksSubscribeAwait(Duration sinksSubscribeAwait)

    • toString

      public String toString()
      覆盖:
      toString 在类中 Object

    • addProperties

      public void addProperties(String key, Object value)

    • addCommonProperties

      public void addCommonProperties(Properties commonProperties)