Searched refs:q_buf_max_ms (Results 1 – 3 of 3) sorted by relevance
51 q_buf_max_ms = 1000; // Default is 1 sec in Config()507 q_buf_max_ms = node["queue.buffering.max.ms"].as<int>(); in parseKafka()509 if (q_buf_max_ms < 1 || q_buf_max_ms > 900000) in parseKafka()514 q_buf_max_ms << std::endl; in parseKafka()
57 int q_buf_max_ms; ///< Max time for buffering msgs in queue variable
166 std::ostringstream q_buf_max_msgs, q_buf_max_kbytes, q_buf_max_ms, in connect() local204 q_buf_max_ms << cfg->q_buf_max_ms; in connect()205 if (conf->set("queue.buffering.max.ms", q_buf_max_ms.str(), errstr) != RdKafka::Conf::CONF_OK) { in connect()