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

类 ConsumerProperties

java.lang.Object
io.github.wooenrico.kafka.consumer.ConsumerProperties
直接已知子类:
ExecutorConsumerProperties
public class ConsumerProperties extends Object
消费者配置

  • 构造器详细资料

    • ConsumerProperties

      public ConsumerProperties()

  • 方法详细资料

    • toString

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

    • isEnabled

      public boolean isEnabled()

    • setEnabled

      public void setEnabled(boolean enabled)

    • getProperties

      public Properties getProperties()

    • setProperties

      public void setProperties(Properties properties)

    • getPollTimeout

      public Duration getPollTimeout()

    • setPollTimeout

      public void setPollTimeout(Duration pollTimeout)

    • getCloseTimeout

      public Duration getCloseTimeout()

    • setCloseTimeout

      public void setCloseTimeout(Duration closeTimeout)

    • getConcurrency

      public int getConcurrency()

    • setConcurrency

      public void setConcurrency(int concurrency)

    • getTopic

      public List<String> getTopic()

    • setTopic

      public void setTopic(List<String> topic)

    • addProperties

      public void addProperties(String key, Object value)

    • addCommonProperties

      public void addCommonProperties(Properties commonProperties)