Home
last modified time | relevance | path

Searched refs:UnsupportedCodecError (Results 1 – 7 of 7) sorted by relevance

/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/producer/
H A Dbase.py18 kafka_errors, UnsupportedCodecError, FailedPayloadsError,
319 raise UnsupportedCodecError("Codec 0x%02x unsupported" % (codec,))
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/
H A Dlegacy.py17 from kafka.errors import ProtocolError, UnsupportedCodecError
474 raise UnsupportedCodecError("Codec 0x%02x unsupported" % (codec,))
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/record/
H A Dlegacy_records.py55 from kafka.errors import CorruptRecordException, UnsupportedCodecError
124 raise UnsupportedCodecError(
H A Ddefault_records.py63 from kafka.errors import CorruptRecordException, UnsupportedCodecError
113 raise UnsupportedCodecError(
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/
H A Derrors.py489 class UnsupportedCodecError(KafkaError): class
/dports/net/py-kafka-python/kafka-python-1.4.5/test/
H A Dtest_consumer_integration.py20 KafkaTimeoutError, UnsupportedCodecError
71 with pytest.raises(UnsupportedCodecError, match=error_msg):
H A Dtest_protocol_legacy.py11 ChecksumError, KafkaUnavailableError, UnsupportedCodecError,
847 with self.assertRaises(UnsupportedCodecError):