/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/ |
H A D | test_Admin.py | 5 from confluent_kafka import KafkaException, KafkaError, libversion 36 except KafkaException as e: 67 with pytest.raises(KafkaException): 74 with pytest.raises(KafkaException): 89 assert isinstance(e, KafkaException) 137 with pytest.raises(KafkaException): 146 assert isinstance(e, KafkaException) 179 with pytest.raises(KafkaException): 193 assert isinstance(e, KafkaException) 222 with pytest.raises(KafkaException): [all …]
|
H A D | test_Consumer.py | 4 KafkaException, TIMESTAMP_NOT_AVAILABLE, 58 with pytest.raises(KafkaException) as ex: 80 except KafkaException as e: 90 except KafkaException as e: 99 except KafkaException as e: 104 except KafkaException as e: 109 except KafkaException as e: 130 except KafkaException as e: 176 except KafkaException as e: 206 except KafkaException as e:
|
H A D | test_KafkaError.py | 4 from confluent_kafka import Producer, KafkaError, KafkaException 43 with pytest.raises(KafkaException) as exc: 53 class MyExc(KafkaException): 58 assert isinstance(err, KafkaException)
|
H A D | test_Producer.py | 5 from confluent_kafka import Producer, KafkaError, KafkaException, libversion 43 except KafkaException as e: 138 with pytest.raises(KafkaException): 188 with pytest.raises(KafkaException) as ex:
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/kafkatest/ |
H A D | verifiable_producer.py | 20 from confluent_kafka import Producer, KafkaException 113 except KafkaException as e:
|
H A D | verifiable_consumer.py | 21 from confluent_kafka import Consumer, KafkaError, KafkaException 170 except KafkaException as e:
|
/dports/devel/aws-sdk-php/aws-sdk-php74-3.185.15/Aws/Kafka/Exception/ |
H A D | KafkaException.php | 9 class KafkaException extends AwsException {} class
|
/dports/www/nextcloud/nextcloud/3rdparty/aws/aws-sdk-php/src/Kafka/Exception/ |
H A D | KafkaException.php | 9 class KafkaException extends AwsException {} class
|
/dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/_drivers/ |
H A D | impl_kafka.py | 19 from confluent_kafka import KafkaException 75 class ConsumerTimeout(KafkaException): 272 except KafkaException as e: 313 except KafkaException:
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/admin/ |
H A D | __init__.py | 4 from ..cimpl import (KafkaException, # noqa 233 fut.set_exception(KafkaException(error)) 256 fut.set_exception(KafkaException(resource.error))
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
H A D | confluent_kafka.h | 165 extern PyObject *KafkaException; 178 PyErr_SetObject(KafkaException, _eo); \
|
H A D | confluent_kafka.c | 37 PyObject *KafkaException; variable 328 PyErr_SetObject(KafkaException, eo); in cfl_PyErr_Fatal() 2356 KafkaException = PyErr_NewExceptionWithDoc( in _init_cimpl() 2366 KafkaException = PyErr_NewException("cimpl.KafkaException", NULL, NULL); in _init_cimpl() 2368 Py_INCREF(KafkaException); in _init_cimpl() 2369 PyModule_AddObject(m, "KafkaException", KafkaException); in _init_cimpl()
|
H A D | Admin.c | 1439 exctype = KafkaException; in Admin_background_event_cb()
|
/dports/devel/spark/spark-2.1.1/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/ |
H A D | CachedKafkaConsumer.scala | 23 import org.apache.kafka.common.{ KafkaException, TopicPartition } 130 case x: KafkaException =>
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/ |
H A D | __init__.py | 4 KafkaException,
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/java/ |
H A D | IncrementalRebalanceCli.java | 38 import org.apache.kafka.common.KafkaException;
|
H A D | TransactionProducerCli.java | 36 import org.apache.kafka.common.KafkaException;
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/java/ |
H A D | IncrementalRebalanceCli.java | 38 import org.apache.kafka.common.KafkaException;
|
H A D | TransactionProducerCli.java | 36 import org.apache.kafka.common.KafkaException;
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/java/ |
H A D | TransactionProducerCli.java | 8 import org.apache.kafka.common.KafkaException;
|