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 D | base.py | 18 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 D | legacy.py | 17 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 D | legacy_records.py | 55 from kafka.errors import CorruptRecordException, UnsupportedCodecError 124 raise UnsupportedCodecError(
|
H A D | default_records.py | 63 from kafka.errors import CorruptRecordException, UnsupportedCodecError 113 raise UnsupportedCodecError(
|
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
H A D | errors.py | 489 class UnsupportedCodecError(KafkaError): class
|
/dports/net/py-kafka-python/kafka-python-1.4.5/test/ |
H A D | test_consumer_integration.py | 20 KafkaTimeoutError, UnsupportedCodecError 71 with pytest.raises(UnsupportedCodecError, match=error_msg):
|
H A D | test_protocol_legacy.py | 11 ChecksumError, KafkaUnavailableError, UnsupportedCodecError, 847 with self.assertRaises(UnsupportedCodecError):
|