Interface IMockedConfluentConsumer

Namespace

Silverback.Messaging.Broker.Kafka.Mocks

Assembly

Silverback.Integration.Kafka.Testing.dll

A mocked implementation of Confluent.Kafka.IConsumer<TKey, TValue> from Confluent.Kafka that consumes from an IInMemoryTopic.

public interface IMockedConfluentConsumer : IConsumer<byte[]?, byte[]?>, IClient, IDisposable

Inherited Members

IConsumer<byte[], byte[]>.Consume(int)

IConsumer<byte[], byte[]>.Consume(CancellationToken)

IConsumer<byte[], byte[]>.Consume(TimeSpan)

IConsumer<byte[], byte[]>.Subscribe(IEnumerable<string>)

IConsumer<byte[], byte[]>.Subscribe(string)

IConsumer<byte[], byte[]>.Unsubscribe()

IConsumer<byte[], byte[]>.Assign(TopicPartition)

IConsumer<byte[], byte[]>.Assign(TopicPartitionOffset)

IConsumer<byte[], byte[]>.Assign(IEnumerable<TopicPartitionOffset>)

IConsumer<byte[], byte[]>.Assign(IEnumerable<TopicPartition>)

IConsumer<byte[], byte[]>.IncrementalAssign(IEnumerable<TopicPartitionOffset>)

IConsumer<byte[], byte[]>.IncrementalAssign(IEnumerable<TopicPartition>)

IConsumer<byte[], byte[]>.IncrementalUnassign(IEnumerable<TopicPartition>)

IConsumer<byte[], byte[]>.Unassign()

IConsumer<byte[], byte[]>.StoreOffset(ConsumeResult<byte[], byte[]>)

IConsumer<byte[], byte[]>.StoreOffset(TopicPartitionOffset)

IConsumer<byte[], byte[]>.Commit()

IConsumer<byte[], byte[]>.Commit(IEnumerable<TopicPartitionOffset>)

IConsumer<byte[], byte[]>.Commit(ConsumeResult<byte[], byte[]>)

IConsumer<byte[], byte[]>.Seek(TopicPartitionOffset)

IConsumer<byte[], byte[]>.Pause(IEnumerable<TopicPartition>)

IConsumer<byte[], byte[]>.Resume(IEnumerable<TopicPartition>)

IConsumer<byte[], byte[]>.Committed(TimeSpan)

IConsumer<byte[], byte[]>.Committed(IEnumerable<TopicPartition>, TimeSpan)

IConsumer<byte[], byte[]>.Position(TopicPartition)

IConsumer<byte[], byte[]>.OffsetsForTimes(IEnumerable<TopicPartitionTimestamp>, TimeSpan)

IConsumer<byte[], byte[]>.GetWatermarkOffsets(TopicPartition)

IConsumer<byte[], byte[]>.QueryWatermarkOffsets(TopicPartition, TimeSpan)

IConsumer<byte[], byte[]>.Close()

IConsumer<byte[], byte[]>.MemberId

IConsumer<byte[], byte[]>.Assignment

IConsumer<byte[], byte[]>.Subscription

IConsumer<byte[], byte[]>.ConsumerGroupMetadata

IClient.AddBrokers(string)

IClient.SetSaslCredentials(string, string)

IClient.Handle

IClient.Name

IDisposable.Dispose()

Properties

Config

Gets the Confluent.Kafka.ConsumerConfig.

ConsumerConfig Config { get; }

Property Value

ConsumerConfig

IsDisposed

Gets a value indicating whether this instance was disposed.

bool IsDisposed { get; }

Property Value

bool

PartitionsAssigned

Gets a value indicating whether the partitions have been assigned to the consumer, either manually or via rebalance.

bool PartitionsAssigned { get; }

Property Value

bool

Remarks

This value indicates that the rebalance process is over. It could be that no partition has actually been assigned.

Methods

GetStoredOffset(TopicPartition)

Gets the stored offset for the specified topic partition.

TopicPartitionOffset GetStoredOffset(TopicPartition topicPartition)

Parameters

topicPartition TopicPartition

The topic partition.

Returns

TopicPartitionOffset

The Confluent.Kafka.TopicPartitionOffset representing the offset, or Confluent.Kafka.Offset.Unset if the specified topic partition isn't currently assigned to the consumer or no offset has been stored so far.