kafka::utest::KafkaCluster Member List

This is the complete list of members for kafka::utest::KafkaCluster, including all inherited members.

GenerateTopic() (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
GenerateTopics(std::size_t count) (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
KafkaCluster() (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
kDefaultTestProducerTimeout	kafka::utest::KafkaCluster	static
MakeConsumer(const std::string &name, const std::vector< std::string > &topics, impl::ConsumerConfiguration configuration={}, impl::ConsumerExecutionParams params={}) (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
MakeConsumerConfiguration(const std::string &name, impl::ConsumerConfiguration configuration={}, impl::Secret secrets={}) (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
MakeProducer(const std::string &name, impl::ProducerConfiguration configuration={}) (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
MakeProducerConfiguration(const std::string &name, impl::ProducerConfiguration configuration={}, impl::Secret secrets={}) (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
MakeProducers(std::size_t count, std::function< std::string(std::size_t)> nameGenerator, impl::ProducerConfiguration configuration={}) (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster
ReceiveMessages(impl::Consumer &consumer, std::size_t expected_messages_count, bool commit_after_receive=true, std::optional< std::function< void(MessageBatchView)> > user_callback={})	kafka::utest::KafkaCluster
SendMessages(utils::span< const Message > messages)	kafka::utest::KafkaCluster
~KafkaCluster() override=default (defined in kafka::utest::KafkaCluster)	kafka::utest::KafkaCluster