パッケージ org.springframework.boot.autoconfigure.kafka

クラス KafkaProperties.Consumer

java.lang.ObjectSE
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Consumer
含まれているクラス:
KafkaProperties
public static class KafkaProperties.Consumer extends ObjectSE

  • コンストラクターの詳細

    • Consumer

      public Consumer()

  • メソッドの詳細

    • getSsl

      public KafkaProperties.Ssl getSsl()

    • getSecurity

      public KafkaProperties.Security getSecurity()

    • getAutoCommitInterval

      public DurationSE getAutoCommitInterval()

    • setAutoCommitInterval

      public void setAutoCommitInterval(DurationSE autoCommitInterval)

    • getAutoOffsetReset

      public StringSE getAutoOffsetReset()

    • setAutoOffsetReset

      public void setAutoOffsetReset(StringSE autoOffsetReset)

    • getBootstrapServers

      public ListSE<StringSE> getBootstrapServers()

    • setBootstrapServers

      public void setBootstrapServers(ListSE<StringSE> bootstrapServers)

    • getClientId

      public StringSE getClientId()

    • setClientId

      public void setClientId(StringSE clientId)

    • getEnableAutoCommit

      public BooleanSE getEnableAutoCommit()

    • setEnableAutoCommit

      public void setEnableAutoCommit(BooleanSE enableAutoCommit)

    • getFetchMaxWait

      public DurationSE getFetchMaxWait()

    • setFetchMaxWait

      public void setFetchMaxWait(DurationSE fetchMaxWait)

    • getFetchMinSize

      public DataSize getFetchMinSize()

    • setFetchMinSize

      public void setFetchMinSize(DataSize fetchMinSize)

    • getGroupId

      public StringSE getGroupId()

    • setGroupId

      public void setGroupId(StringSE groupId)

    • getHeartbeatInterval

      public DurationSE getHeartbeatInterval()

    • setHeartbeatInterval

      public void setHeartbeatInterval(DurationSE heartbeatInterval)

    • getIsolationLevel

      public KafkaProperties.IsolationLevel getIsolationLevel()

    • setIsolationLevel

      public void setIsolationLevel(KafkaProperties.IsolationLevel isolationLevel)

    • getKeyDeserializer

      public ClassSE<?> getKeyDeserializer()

    • setKeyDeserializer

      public void setKeyDeserializer(ClassSE<?> keyDeserializer)

    • getValueDeserializer

      public ClassSE<?> getValueDeserializer()

    • setValueDeserializer

      public void setValueDeserializer(ClassSE<?> valueDeserializer)

    • getMaxPollRecords

      public IntegerSE getMaxPollRecords()

    • setMaxPollRecords

      public void setMaxPollRecords(IntegerSE maxPollRecords)

    • getProperties

      public MapSE<StringSE,StringSE> getProperties()

    • buildProperties

      public MapSE<StringSE,ObjectSE> buildProperties(SslBundles sslBundles)