Home
last modified time | relevance | path

Searched refs:KafkaException (Results 1 – 20 of 20) sorted by relevance

/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/
H A Dtest_Admin.py5 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 Dtest_Consumer.py4 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 Dtest_KafkaError.py4 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 Dtest_Producer.py5 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 Dverifiable_producer.py20 from confluent_kafka import Producer, KafkaException
113 except KafkaException as e:
H A Dverifiable_consumer.py21 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 DKafkaException.php9 class KafkaException extends AwsException {} class
/dports/www/nextcloud/nextcloud/3rdparty/aws/aws-sdk-php/src/Kafka/Exception/
H A DKafkaException.php9 class KafkaException extends AwsException {} class
/dports/devel/py-oslo.messaging/oslo.messaging-12.11.0/oslo_messaging/_drivers/
H A Dimpl_kafka.py19 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__.py4 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 Dconfluent_kafka.h165 extern PyObject *KafkaException;
178 PyErr_SetObject(KafkaException, _eo); \
H A Dconfluent_kafka.c37 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 DAdmin.c1439 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 DCachedKafkaConsumer.scala23 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__.py4 KafkaException,
/dports/net/librdkafka/librdkafka-1.8.2/tests/java/
H A DIncrementalRebalanceCli.java38 import org.apache.kafka.common.KafkaException;
H A DTransactionProducerCli.java36 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 DIncrementalRebalanceCli.java38 import org.apache.kafka.common.KafkaException;
H A DTransactionProducerCli.java36 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 DTransactionProducerCli.java8 import org.apache.kafka.common.KafkaException;