Interface IMockedConfluentConsumer

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

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()

Namespace: Silverback.Messaging.Broker.Kafka.Mocks

Assembly: Silverback.Integration.Kafka.Testing.dll

Syntax

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

Properties

Disposed

Gets a value indicating whether this instance was disposed.

Declaration

bool Disposed { get; }

Property Value

Type	Description
bool

EnablePartitionEof

Gets a value indicating whether the partition EOF event has to be emitted.

Declaration

bool EnablePartitionEof { get; }

Property Value

Type	Description
bool

GroupId

Gets the consumer group id.

Declaration

string GroupId { get; }

Property Value

Type	Description
string

PartitionsAssigned

Gets a value indicating whether the partitions have been assigned to the consumer.

Declaration

bool PartitionsAssigned { get; }

Property Value

Type	Description
bool

Remarks

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