クラス KafkaProperties.Consumer

java.lang.ObjectSE
org.springframework.boot.kafka.autoconfigure.KafkaProperties.Consumer
含まれているクラス:
KafkaProperties
public static class KafkaProperties.Consumer extends ObjectSE
導入:
4.0.0
作成者:
Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes, Andy Wilkinson, Scott Frederick, Yanming Zhou

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

    • Consumer

      public Consumer()

  • メソッドの詳細

    • getSsl

      public KafkaProperties.Ssl getSsl()

    • getSecurity

      public KafkaProperties.Security getSecurity()

    • getAutoCommitInterval

      public @Nullable DurationSE getAutoCommitInterval()

    • setAutoCommitInterval

      public void setAutoCommitInterval(@Nullable DurationSE autoCommitInterval)

    • getAutoOffsetReset

      public @Nullable StringSE getAutoOffsetReset()

    • setAutoOffsetReset

      public void setAutoOffsetReset(@Nullable StringSE autoOffsetReset)

    • getBootstrapServers

      public @Nullable ListSE<StringSE> getBootstrapServers()

    • setBootstrapServers

      public void setBootstrapServers(@Nullable ListSE<StringSE> bootstrapServers)

    • getClientId

      public @Nullable StringSE getClientId()

    • setClientId

      public void setClientId(@Nullable StringSE clientId)

    • getEnableAutoCommit

      public @Nullable BooleanSE getEnableAutoCommit()

    • setEnableAutoCommit

      public void setEnableAutoCommit(@Nullable BooleanSE enableAutoCommit)

    • getFetchMaxWait

      public @Nullable DurationSE getFetchMaxWait()

    • setFetchMaxWait

      public void setFetchMaxWait(@Nullable DurationSE fetchMaxWait)

    • getFetchMinSize

      public @Nullable DataSize getFetchMinSize()

    • setFetchMinSize

      public void setFetchMinSize(@Nullable DataSize fetchMinSize)

    • getGroupId

      public @Nullable StringSE getGroupId()

    • setGroupId

      public void setGroupId(@Nullable StringSE groupId)

    • getHeartbeatInterval

      public @Nullable DurationSE getHeartbeatInterval()

    • setHeartbeatInterval

      public void setHeartbeatInterval(@Nullable 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 @Nullable IntegerSE getMaxPollRecords()

    • setMaxPollRecords

      public void setMaxPollRecords(@Nullable IntegerSE maxPollRecords)

    • getMaxPollInterval

      public @Nullable DurationSE getMaxPollInterval()

    • setMaxPollInterval

      public void setMaxPollInterval(@Nullable DurationSE maxPollInterval)

    • getProperties

      public MapSE<StringSE,StringSE> getProperties()

    • buildProperties

      public MapSE<StringSE,ObjectSE> buildProperties()