final class Builder extends AnyRef
Builder for consumer settings
- Alphabetic
- By Inheritance
- Builder
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Builder()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def build: ConsumerSettings
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withConsumerId(consumerId: String): Builder
- consumerId
The ID to use to identify this consumer. It must be unique within the consumer group. If you do not provide one, the system will generate one. This parameter is applicable only for http-connector.
- returns
builder
- See also
- def withEarliestOffset(): Builder
Subscribe for earliest offset (old) available for selected group name.
Subscribe for earliest offset (old) available for selected group name. For already existent group name, all partitions since last checkpoint will be returned. For new group name, all partitions available.
- returns
builder
- def withGroupName(groupName: String): Builder
- groupName
name of a consumer group. A string that uniquely identifies the group of consumer processes to which this consumer belongs. By setting the same group name multiple processes indicate that they are all part of the same consumer group. Maximum length of this field is 1000 characters.
- returns
builder
- See also
- def withLatestOffset(): Builder
Subscribe only to new partitions.
Subscribe only to new partitions. Any previous data published prior to the subscription will be skipped. Use this offset if you are interested only into new partitions.
LatestOffset completely ignore previously existing checkpoint for same groupName, all leases are created with the latest offset available. This means that during the stream partitions id re-balance between workers, there is no guarantee that all events will be processed.
- returns
builder
- def withManualLatestOffset(): Builder
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint], starting from the latest available offsets if no previous offsets were committed.
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint], starting from the latest available offsets if no previous offsets were committed.
This setting cannot be used with FlinkQueryApi subscribe method, because there is no interface that allows to acknowledge partitions manually.
- returns
builder
- def withManualOffset(): Builder
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint], starting from the earliest available offsets if no previous offsets were committed.
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint], starting from the earliest available offsets if no previous offsets were committed.
This setting cannot be used with FlinkQueryApi subscribe method, because there is no interface that allows to acknowledge partitions manually.
- returns
builder
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)