Method SetTopicMetadata

mocks/consumer.go:196–201

Expectation API SetTopicMetadata sets the clusters topic/partition metadata, which will be returned by Topics() and Partitions().

(metadata map[string][]int32)

// SetTopicMetadata sets the clusters topic/partition metadata,
// which will be returned by Topics() and Partitions().
func (c *Consumer) SetTopicMetadata(metadata map[string][]int32) {
	c.l.Lock()
	defer c.l.Unlock()

	c.metadata = metadata
}

// ExpectConsumePartition will register a topic/partition, so you can set expectations on it.
// The registered PartitionConsumer will be returned, so you can set expectations