Page History

...

The JIRA for this API is here.

OffsetCommit

This api saves out the consumer's position in the stream for one or more partitions. In the scala API this happens when the consumer calls commit() or in the background if "autocommit" is enabled. This is the position the consumer will pick up from if it crashes before its next commit().

Request:

OffsetCommitRequest => ConsumerGroup [TopicName [Partition Offset]]
  ConsumerGroup => string
  TopicName => string
  Partition => int32
  Offset => int64

...

OffsetCommitResponse => TopicName [Partition ErrorCode]]
  ErrorCode => int16

OffsetFetch

This api reads back a consumer position previously written using the OffsetCommit api.

Request:

OffsetFetchRequest => ConsumerGroup [TopicName [Partition]]

...