IConsumer interface
Represents a KafkaFlow consumer
public interface IConsumer : IDisposable
Members
| name | description |
|---|---|
| Assignment { get; } | |
| ClientInstanceName { get; } | |
| Configuration { get; } | Gets the consumer configuration |
| FlowManager { get; } | Gets the consumer IConsumerFlowManager |
| MaxPollIntervalExceeded { get; } | Gets the event for subscribing to notifications when the consumer's maximum polling interval is exceeded. |
| MemberId { get; } | |
| Status { get; } | Gets the current consumer status |
| Subscription { get; } | |
| Commit(…) | |
| ConsumeAsync(…) | |
| GetPosition(…) | |
| GetTopicPartitionsLag() | Gets the lag of each topic/partitions assigned |
| GetWatermarkOffsets(…) | |
| OffsetsForTimes(…) | |
| OnError(…) | Register a handler to be executed when an error occurs |
| OnPartitionsAssigned(…) | Register a handler to be executed when the partitions are assigned |
| OnPartitionsRevoked(…) | Register a handler to be executed when the partitions are revoked |
| OnStatistics(…) | Register a handler to be executed to receive statistics information |
| QueryWatermarkOffsets(…) |
See Also
- namespace KafkaFlow.Consumers