object ConsumerSettings

Source
ConsumerSettings.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply[K, V](config: Config, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer.

    Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer. Key and value serializer must be passed explicitly.

  2. def apply[K, V](system: ClassicActorSystemProvider, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Create settings from the default configuration akka.kafka.consumer.

    Create settings from the default configuration akka.kafka.consumer. Key and value serializer must be passed explicitly.

    For use with the akka.actor.typed API.

  3. def apply[K, V](system: ActorSystem, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Create settings from the default configuration akka.kafka.consumer.

    Create settings from the default configuration akka.kafka.consumer. Key and value serializer must be passed explicitly.

  4. def apply[K, V](config: Config, keyDeserializer: Option[Deserializer[K]], valueDeserializer: Option[Deserializer[V]]): ConsumerSettings[K, V]

    Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer.

    Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer. Key or value deserializer can be passed explicitly or retrieved from configuration.

  5. def apply[K, V](system: ClassicActorSystemProvider, keyDeserializer: Option[Deserializer[K]], valueDeserializer: Option[Deserializer[V]]): ConsumerSettings[K, V]

    Create settings from the default configuration akka.kafka.consumer.

    Create settings from the default configuration akka.kafka.consumer. Key or value deserializer can be passed explicitly or retrieved from configuration.

    For use with the akka.actor.typed API.

  6. def apply[K, V](system: ActorSystem, keyDeserializer: Option[Deserializer[K]], valueDeserializer: Option[Deserializer[V]]): ConsumerSettings[K, V]

    Create settings from the default configuration akka.kafka.consumer.

    Create settings from the default configuration akka.kafka.consumer. Key or value deserializer can be passed explicitly or retrieved from configuration.

  7. val configPath: String
  8. def create[K, V](config: Config, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Java API: Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer.

    Java API: Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer. Key and value serializer must be passed explicitly.

  9. def create[K, V](system: ClassicActorSystemProvider, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Java API: Create settings from the default configuration akka.kafka.consumer.

    Java API: Create settings from the default configuration akka.kafka.consumer. Key and value serializer must be passed explicitly.

    For use with the akka.actor.typed API.

  10. def create[K, V](system: ActorSystem, keyDeserializer: Deserializer[K], valueDeserializer: Deserializer[V]): ConsumerSettings[K, V]

    Java API: Create settings from the default configuration akka.kafka.consumer.

    Java API: Create settings from the default configuration akka.kafka.consumer. Key and value serializer must be passed explicitly.

  11. def create[K, V](config: Config, keyDeserializer: Optional[Deserializer[K]], valueDeserializer: Optional[Deserializer[V]]): ConsumerSettings[K, V]

    Java API: Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer.

    Java API: Create settings from a configuration with the same layout as the default configuration akka.kafka.consumer. Key or value deserializer can be passed explicitly or retrieved from configuration.

  12. def create[K, V](system: ClassicActorSystemProvider, keyDeserializer: Optional[Deserializer[K]], valueDeserializer: Optional[Deserializer[V]]): ConsumerSettings[K, V]

    Java API: Create settings from the default configuration akka.kafka.consumer.

    Java API: Create settings from the default configuration akka.kafka.consumer. Key or value deserializer can be passed explicitly or retrieved from configuration.

    For use with the akka.actor.typed API.

  13. def create[K, V](system: ActorSystem, keyDeserializer: Optional[Deserializer[K]], valueDeserializer: Optional[Deserializer[V]]): ConsumerSettings[K, V]

    Java API: Create settings from the default configuration akka.kafka.consumer.

    Java API: Create settings from the default configuration akka.kafka.consumer. Key or value deserializer can be passed explicitly or retrieved from configuration.

  14. def createKafkaConsumer[K, V](settings: ConsumerSettings[K, V]): Consumer[K, V]

    Create a KafkaConsumer instance from the settings.