Packages

o

org.apache.pekko.kafka.internal

PartitionAssignmentHelpers

object PartitionAssignmentHelpers

Internal API.

Implementations of PartitionAssignmentHandler for internal use.

Annotations
@InternalApi()
Source
PartitionAssignmentHelpers.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PartitionAssignmentHelpers
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final class AsyncCallbacks extends PartitionAssignmentHandler
    Annotations
    @InternalApi()
  2. final class Chain extends PartitionAssignmentHandler
    Annotations
    @InternalApi()
  3. final case class WrappedJava(handler: PartitionAssignmentHandler) extends PartitionAssignmentHandler with Product with Serializable
    Annotations
    @InternalApi()

Value Members

  1. def chain(handler1: PartitionAssignmentHandler, handler2: PartitionAssignmentHandler): PartitionAssignmentHandler
  2. object EmptyPartitionAssignmentHandler extends PartitionAssignmentHandler
    Annotations
    @InternalApi()