Searched defs:KafkaError (Results 1 – 11 of 11) sorted by relevance
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/ |
| H A D | error.rs | 40 pub enum KafkaError { enum
83 impl fmt::Debug for KafkaError { implementation
136 impl fmt::Display for KafkaError { implementation
169 impl error::Error for KafkaError { implementation
222 impl From<ffi::NulError> for KafkaError { implementation
223 fn from(err: ffi::NulError) -> KafkaError { in from()
|
| H A D | client.rs | 90 fn error(&self, error: KafkaError, reason: &str) { in error() method
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-kafka/include/aws/kafka/ |
| H A D | KafkaErrors.h | 62 KafkaError() {} in KafkaError() function
63 …KafkaError(const Aws::Client::AWSError<Aws::Client::CoreErrors>& rhs) : Aws::Client::AWSError<Kafk… in KafkaError() function
64 …KafkaError(Aws::Client::AWSError<Aws::Client::CoreErrors>&& rhs) : Aws::Client::AWSError<KafkaErro… in KafkaError() function
65 …KafkaError(const Aws::Client::AWSError<KafkaErrors>& rhs) : Aws::Client::AWSError<KafkaErrors>(rhs… in KafkaError() function
66 KafkaError(Aws::Client::AWSError<KafkaErrors>&& rhs) : Aws::Client::AWSError<KafkaErrors>(rhs) {} in KafkaError() function
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/examples/ |
| H A D | example-consume.rs | 23 fn consume_messages(group: String, topic: String, brokers: Vec<String>) -> Result<(), KafkaError> { in consume_messages() argument
|
| H A D | example-produce.rs | 29 ) -> Result<(), KafkaError> { in produce_message() argument
|
| /dports/sysutils/vector/vector-0.10.0/src/ |
| H A D | kafka.rs | 8 enum KafkaError { enum
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/producer/ |
| H A D | base_producer.rs | 360 ) -> Result<(), (KafkaError, BaseRecord<'a, K, P, C::DeliveryOpaque>)> in send()
510 ) -> Result<(), (KafkaError, BaseRecord<'a, K, P, C::DeliveryOpaque>)> in send()
|
| H A D | future_producer.rs | 147 fn error(&self, error: KafkaError, reason: &str) { in error() method
331 ) -> Result<DeliveryFuture, (KafkaError, FutureRecord<'a, K, P>)> in send_result()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/consumer/ |
| H A D | stream_consumer.rs | 54 fn error(&self, error: KafkaError, reason: &str) { in error() method
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
| H A D | errors.py | 7 class KafkaError(RuntimeError): class
|
| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | confluent_kafka.c | 66 } KafkaError; typedef
|