object Metadata
Messages for Kafka metadata fetching via KafkaConsumerActor.
NOTE: Processing of these requests blocks the actor loop. The KafkaConsumerActor is configured to run on its own dispatcher, so just as the other remote calls to Kafka, the blocking happens within a designated thread pool. However, calling these during consuming might affect performance and even cause timeouts in extreme cases.
- Source
- Metadata.scala
- Alphabetic
- By Inheritance
- Metadata
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class BeginningOffsets(response: Try[Map[TopicPartition, Long]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- final case class CommittedOffsets(response: Try[Map[TopicPartition, OffsetAndMetadata]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- final case class EndOffsets(response: Try[Map[TopicPartition, Long]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- final case class GetBeginningOffsets(partitions: Set[TopicPartition]) extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#beginningOffsets()
org.apache.kafka.clients.consumer.KafkaConsumer#beginningOffsets()
Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.
- final case class GetCommittedOffsets(partitions: Set[TopicPartition]) extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#committed()
- final case class GetEndOffsets(partitions: Set[TopicPartition]) extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#endOffsets()
org.apache.kafka.clients.consumer.KafkaConsumer#endOffsets()
Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.
- final case class GetOffsetsForTimes(timestampsToSearch: Map[TopicPartition, Long]) extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#offsetsForTimes()
org.apache.kafka.clients.consumer.KafkaConsumer#offsetsForTimes()
Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.
- final case class GetPartitionsFor(topic: String) extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#partitionsFor()
- final case class OffsetsForTimes(response: Try[Map[TopicPartition, OffsetAndTimestamp]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- final case class PartitionsFor(response: Try[List[PartitionInfo]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- sealed trait Request extends AnyRef
- sealed trait Response extends AnyRef
- final case class Topics(response: Try[Map[String, List[PartitionInfo]]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
Deprecated Type Members
- final case class CommittedOffset(response: Try[OffsetAndMetadata], requestedPartition: TopicPartition) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- Annotations
- @deprecated
- Deprecated
(Since version Alpakka Kafka 2.0.3) use
CommittedOffsets
- final case class GetCommittedOffset(partition: TopicPartition) extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#committed()
org.apache.kafka.clients.consumer.KafkaConsumer#committed()
- Annotations
- @deprecated
- Deprecated
(Since version Alpakka Kafka 2.0.3) use
GetCommittedOffsets
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 clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createGetBeginningOffsets(partitions: Set[TopicPartition]): GetBeginningOffsets
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#beginningOffsets()
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#beginningOffsets()
Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.
- def createGetCommittedOffsets(partitions: Set[TopicPartition]): GetCommittedOffsets
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#committed()
- def createGetEndOffsets(partitions: Set[TopicPartition]): GetEndOffsets
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#endOffsets()
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#endOffsets()
Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.
- def createGetOffsetForTimes(timestampsToSearch: Map[TopicPartition, Long]): GetOffsetsForTimes
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#offsetsForTimes()
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#offsetsForTimes()
Warning: KafkaConsumer documentation states that this method may block indefinitely if the partition does not exist.
- def createGetPartitionsFor(topic: String): GetPartitionsFor
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#partitionsFor()
- def createListTopics: ListTopics.type
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#listTopics()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()
- case object ListTopics extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#listTopics()
Deprecated Value Members
- def createGetCommittedOffset(partition: TopicPartition): GetCommittedOffset
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#committed()
Java API: org.apache.kafka.clients.consumer.KafkaConsumer#committed()
- Annotations
- @deprecated
- Deprecated
(Since version Alpakka Kafka 2.0.3) use
createGetCommittedOffsets