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
- All
Type Members
- final case class BeginningOffsets(response: Try[Map[TopicPartition, Long]]) extends Response with NoSerializationVerificationNeeded with Product with Serializable
- final case class CommittedOffset(response: Try[OffsetAndMetadata], requestedPartition: TopicPartition) 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
GetCommittedOffset(partition: 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
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[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
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
createGetCommittedOffset(partition: TopicPartition): GetCommittedOffset
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: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
object
ListTopics extends Request with NoSerializationVerificationNeeded with Product with Serializable
org.apache.kafka.clients.consumer.KafkaConsumer#listTopics()
Deprecated Value Members
-
def
createGetCommitedOffset(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 1.0-M1) Use createGetCommittedOffset(...) instead
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
- Deprecated
(Since version ) see corresponding Javadoc for more information.