Class RebalanceResult

Namespace

Silverback.Messaging.Broker.Kafka.Mocks

Assembly

Silverback.Integration.Kafka.Testing.dll

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

public class RebalanceResult

Inheritance

object

RebalanceResult

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

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

Initializes a new instance of the RebalanceResult class.

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

Parameters

assignedPartitions IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>

The partitions that have been assigned.

revokedPartitions IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>

The partitions that have been revoked.

Fields

Empty

An empty RebalanceResult.

public static readonly RebalanceResult Empty

Field Value

RebalanceResult

Properties

AssignedPartitions

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

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

Property Value

IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>

RevokedPartitions

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

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

Property Value

IReadOnlyDictionary<IMockedConfluentConsumer, IReadOnlyCollection<TopicPartition>>