This is the complete list of members for kafka::utest::KafkaCluster, including all inherited members.
| GenerateTopic(std::uint32_t partition_cnt=1) (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 | |
| ReceiveMessages(ConsumerScope &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 (defined in kafka::utest::KafkaCluster) | kafka::utest::KafkaCluster |
