Package com.here.platform.data.client.settings

Class ConsumerSettings

java.lang.Object

com.here.platform.data.client.settings.ConsumerSettings

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class ConsumerSettings
extends Object
implements scala.Product, Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ConsumerSettings.Builder

Constructor Summary

Constructors

Constructor	Description
ConsumerSettings(String groupName, Offset offset, String consumerId)

Method Summary

Modifier and Type	Method	Description
String	consumerId()
scala.concurrent.duration.FiniteDuration	consumerIdleInterval()
String	groupName()
scala.concurrent.duration.FiniteDuration	leaseRenewInterval()
scala.concurrent.duration.FiniteDuration	leaseTakeDuration()
scala.concurrent.duration.FiniteDuration	leaseTakeInterval()
scala.Option<scala.Function1<Object,scala.runtime.BoxedUnit>>	metricReporterCallback()
Offset	offset()
ConsumerSettings	withReporterCallback(scala.Function1<Object,scala.runtime.BoxedUnit> callback)

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

ConsumerSettings

public ConsumerSettings(String groupName,
 Offset offset,
 String consumerId)

Method Details

groupName

public String groupName()

offset

public Offset offset()

consumerId

public String consumerId()

consumerIdleInterval

public scala.concurrent.duration.FiniteDuration consumerIdleInterval()

leaseRenewInterval

public scala.concurrent.duration.FiniteDuration leaseRenewInterval()

leaseTakeDuration

public scala.concurrent.duration.FiniteDuration leaseTakeDuration()

leaseTakeInterval

public scala.concurrent.duration.FiniteDuration leaseTakeInterval()

metricReporterCallback

public scala.Option<scala.Function1<Object,scala.runtime.BoxedUnit>> metricReporterCallback()

withReporterCallback

public ConsumerSettings withReporterCallback(scala.Function1<Object,scala.runtime.BoxedUnit> callback)