kafkatest

Documentation

Index

• type MockKafkaConsumer
  • func (c *MockKafkaConsumer) CommitMessages(ctx context.Context, msgs ...kafka.Message) error
  • func (c *MockKafkaConsumer) FetchMessage(ctx context.Context) (kafka.Message, error)
• type MockKafkaProducer
  • func (p *MockKafkaProducer) WriteMessages(ctx context.Context, msgs ...kafka.Message) error

Types

type MockKafkaConsumer

type MockKafkaConsumer struct {
	mock.Mock
}

MockKafkaConsumer is used to mock a Kafka consumer.

func (*MockKafkaConsumer) CommitMessages

func (c *MockKafkaConsumer) CommitMessages(ctx context.Context, msgs ...kafka.Message) error

func (*MockKafkaConsumer) FetchMessage

func (c *MockKafkaConsumer) FetchMessage(ctx context.Context) (kafka.Message, error)

type MockKafkaProducer

type MockKafkaProducer struct {
	mock.Mock
}

MockKafkaProducer is used to mock a Kafka producer.

func (*MockKafkaProducer) WriteMessages

func (p *MockKafkaProducer) WriteMessages(ctx context.Context, msgs ...kafka.Message) error