Package com.here.platform.data.client.service.stream

Class CheckpointMark

java.lang.Object

com.here.platform.data.client.service.stream.CheckpointMark

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class CheckpointMark
extends Object
implements scala.Product, Serializable

This class represents consumer offsets state attached to a consumed partition. It can be used to commit offsets back to kafka broker or Stream REST API

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CheckpointMark(String kafkaPartitionId, long offset)

Method Summary

Modifier and Type	Method	Description
abstract static R	apply(T1 v1, T2 v2)
String	kafkaPartitionId()
long	nextOffset()	an offset value that should be commited to Kafka broker, see
long	offset()
static String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

CheckpointMark

public CheckpointMark(String kafkaPartitionId,
 long offset)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2)

toString

public static String toString()

kafkaPartitionId

public String kafkaPartitionId()

offset

public long offset()

nextOffset

public long nextOffset()

an offset value that should be commited to Kafka broker, see