Searched refs:topic_conf (Results 1 – 1 of 1) sorted by relevance
254 std::unique_ptr<RdKafka::Conf> topic_conf( in SetupStreamsLocked() local260 conf->set("default_topic_conf", topic_conf.get(), errstr); in SetupStreamsLocked()