fn convert_to_multiple_entry( provider: Arc<KafkaProvider>, region_id: RegionId, records: Vec<Record>, ) -> Entry