package settings
- Alphabetic
- Public
- All
Type Members
-
case class
ConsumerSettings(groupName: String, offset: Offset = EarliestOffset, consumerId: String = UUID.randomUUID().toString) extends Product with Serializable
Consumer settings object
Consumer settings object
- 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.
- offset
type of offset used in subscription, detailed information can be found on each Offset subclasses
- 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.
- See also
- final case class HereAccountRequestSignerSettings(hereClientId: String, hereAccessKeyId: String, hereAccessKeySecret: String, hereTokenEndpointUrl: Option[String] = None, hereTokenScope: Option[String] = None) extends RequestSignerSettings with Product with Serializable
- final case class HereTokenRequestSignerSettings(hereToken: String) extends RequestSignerSettings with Product with Serializable
-
case class
NotificationConsumerSettings(groupName: String) extends Product with Serializable
Notification consumer settings object
Notification consumer settings object
- groupName
name of a consumer, or groupName if consumer is distributed
-
sealed
trait
Offset extends AnyRef
Type of offsets used during subscriptions.
- final case class RefreshingHereTokenRequestSignerSettings(hereTokenPath: String) extends RequestSignerSettings with Product with Serializable
- sealed trait RequestSignerSettings extends Serializable
- final case class Settings(requestSignerSettings: Option[RequestSignerSettings], billingTag: Option[String], proxySettings: Option[ProxySettings], timeouts: Timeouts = Timeouts.fromDefaults, forceRawData: Boolean = false) extends Product with Serializable
- final case class Timeouts(durableWriteVolumeOverall: Option[FiniteDuration], flinkPublishApi: Option[FiniteDuration], flinkWriteEngine: Option[FiniteDuration]) extends Product with Serializable
Value Members
- object ConsumerSettings extends Serializable
-
object
EarliestOffset extends Offset with Product with Serializable
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.
- object HereAccountRequestSignerSettings extends Serializable
- object HereTokenRequestSignerSettings extends Serializable
-
object
LatestOffset extends Offset with Product with Serializable
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.
- object LocatorContext extends Serializable
-
object
ManualLatestOffset extends Offset with Product with Serializable
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint].
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint].
If no existing offsets are stored, then by default it will start from the latest available messages.
-
object
ManualOffset extends Offset with Product with Serializable
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint].
The offset is manually controlled by user trough [SubscriptionControl.acknowledge] and [SubscriptionControl.checkpoint].
If no existing offsets are stored, then by default it will start from the earliest available messages.
- object NotificationConsumerSettings extends Serializable
- object RefreshingHereTokenRequestSignerSettings extends Serializable
- object Settings extends Serializable
- object Timeouts extends Serializable