Interface IMockedConfluentConsumer

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

Inherited Members

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Consume(System.Int32)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Consume(System.Threading.CancellationToken)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Consume(System.TimeSpan)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Subscribe(System.Collections.Generic.IEnumerable<System.String>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Subscribe(System.String)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Unsubscribe()

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Assign(Confluent.Kafka.TopicPartition)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Assign(Confluent.Kafka.TopicPartitionOffset)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Assign(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Assign(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.IncrementalAssign(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.IncrementalAssign(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.IncrementalUnassign(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Unassign()

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.StoreOffset(Confluent.Kafka.ConsumeResult<System.Byte[], System.Byte[]>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.StoreOffset(Confluent.Kafka.TopicPartitionOffset)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Commit()

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Commit(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionOffset>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Commit(Confluent.Kafka.ConsumeResult<System.Byte[], System.Byte[]>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Seek(Confluent.Kafka.TopicPartitionOffset)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Pause(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Resume(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Committed(System.TimeSpan)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Committed(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartition>, System.TimeSpan)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Position(Confluent.Kafka.TopicPartition)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.OffsetsForTimes(System.Collections.Generic.IEnumerable<Confluent.Kafka.TopicPartitionTimestamp>, System.TimeSpan)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.GetWatermarkOffsets(Confluent.Kafka.TopicPartition)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.QueryWatermarkOffsets(Confluent.Kafka.TopicPartition, System.TimeSpan)

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Close()

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.MemberId

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Assignment

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.Subscription

Confluent.Kafka.IConsumer<System.Byte[], System.Byte[]>.ConsumerGroupMetadata

Confluent.Kafka.IClient.AddBrokers(System.String)

Confluent.Kafka.IClient.SetSaslCredentials(System.String, System.String)

Confluent.Kafka.IClient.Handle

Confluent.Kafka.IClient.Name

System.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
System.Boolean

EnablePartitionEof

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

Declaration

bool EnablePartitionEof { get; }

Property Value

Type	Description
System.Boolean

GroupId

Gets the consumer group id.

Declaration

string GroupId { get; }

Property Value

Type	Description
System.String

PartitionsAssigned

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

Declaration

bool PartitionsAssigned { get; }

Property Value

Type	Description
System.Boolean

Remarks

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