Interface IMockedConfluentProducer

A mocked implementation of Confluent.Kafka.IProducer<TKey, TValue> from Confluent.Kafka that produces to an IInMemoryTopic.

Inherited Members

IProducer<byte[], byte[]>.ProduceAsync(string, Message<byte[], byte[]>, CancellationToken)

IProducer<byte[], byte[]>.ProduceAsync(TopicPartition, Message<byte[], byte[]>, CancellationToken)

IProducer<byte[], byte[]>.Produce(string, Message<byte[], byte[]>, Action<DeliveryReport<byte[], byte[]>>)

IProducer<byte[], byte[]>.Produce(TopicPartition, Message<byte[], byte[]>, Action<DeliveryReport<byte[], byte[]>>)

IProducer<byte[], byte[]>.Poll(TimeSpan)

IProducer<byte[], byte[]>.Flush(TimeSpan)

IProducer<byte[], byte[]>.Flush(CancellationToken)

IProducer<byte[], byte[]>.InitTransactions(TimeSpan)

IProducer<byte[], byte[]>.BeginTransaction()

IProducer<byte[], byte[]>.CommitTransaction(TimeSpan)

IProducer<byte[], byte[]>.CommitTransaction()

IProducer<byte[], byte[]>.AbortTransaction(TimeSpan)

IProducer<byte[], byte[]>.AbortTransaction()

IProducer<byte[], byte[]>.SendOffsetsToTransaction(IEnumerable<TopicPartitionOffset>, IConsumerGroupMetadata, TimeSpan)

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 IMockedConfluentProducer : IProducer<byte[]?, byte[]?>, IClient, IDisposable