Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def build: ConsumerSettings
6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

7.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

8.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

9.  def finalize(): Unit

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

10.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

11.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

13.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

14.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

15.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

16.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

17.  def toString(): String

    Definition Classes

    AnyRef → Any

18.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

19.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

20.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

21.  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

    Get Data from a Stream Layer.

22.  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

23.  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

    group.id.

24.  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

25.  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

26.  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