Class RebalanceResult

Contains the partitions that have been revoked and assigned during the rebalance operation.

Inheritance

object

RebalanceResult

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Broker.Kafka.Mocks

Assembly: Silverback.Integration.Kafka.Testing.dll

Syntax

public class RebalanceResult

Constructors

RebalanceResult(IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>, IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>)

Initializes a new instance of the RebalanceResult class.

Declaration

public RebalanceResult(IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>> assignedPartitions, IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>> revokedPartitions)

Parameters

Type	Name	Description
IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>	assignedPartitions	The partitions that have been assigned.
IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>	revokedPartitions	The partitions that have been revoked.

Fields

Empty

An empty RebalanceResult.

Declaration

public static readonly RebalanceResult Empty

Field Value

Type	Description
RebalanceResult

Properties

AssignedPartitions

Gets the partitions that have been assigned to each involved consumer.

Declaration

public IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>> AssignedPartitions { get; }

Property Value

Type	Description
IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>

RevokedPartitions

Gets the partitions that have been revoked from each involved consumer.

Declaration

public IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>> RevokedPartitions { get; }

Property Value

Type	Description
IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>