Searched refs:MetadataFetch (Results 1 – 3 of 3) sorted by relevance
62 MetadataFetch(RDKafkaError), enumerator112 KafkaError::MetadataFetch(err) => { in fmt()153 KafkaError::MetadataFetch(err) => write!(f, "Meta data fetch error: {}", err), in fmt()182 KafkaError::MetadataFetch(_) => "Meta data fetch error", in description()208 KafkaError::MetadataFetch(ref err) => Some(err), in cause()
244 return Err(KafkaError::MetadataFetch(ret.into())); in fetch_metadata()271 return Err(KafkaError::MetadataFetch(ret.into())); in fetch_watermarks()
389 Err(KafkaError::MetadataFetch(error.into())) in subscription()400 Err(KafkaError::MetadataFetch(error.into())) in assignment()411 return Err(KafkaError::MetadataFetch(assignment_error.into())); in committed()431 Err(KafkaError::MetadataFetch(committed_error.into())) in committed_offsets()446 return Err(KafkaError::MetadataFetch(assignment_error.into())); in offsets_for_timestamp()474 Err(KafkaError::MetadataFetch(offsets_for_times_error.into())) in offsets_for_times()489 Err(KafkaError::MetadataFetch(error.into())) in position()