*/ function kafka_get_err_descs(): array {} /** * Returns an offset value that is $offset before the tail of the topic * * @param int $offset * @return int */ function kafka_offset_tail(int $offset): int {} /** * Retrieve the current number of threads in use by librdkafka. * * @return int */ function kafka_thread_cnt(): int {}