IMessageConsumer.Assignment property
Gets the current partition assignment
public IReadOnlyList<TopicPartition> Assignment \{ get; }
See Also
- interface IMessageConsumer
- namespace KafkaFlow.Consumers
Gets the current partition assignment
public IReadOnlyList<TopicPartition> Assignment \{ get; }