When the broker is not producing, the method `get_watermark_offsets` raises a timeout error... Need to investigate.