コンストラクターの詳細

• 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()